zookeeper

README

Zookeeper Input Plugin

The zookeeper plugin collects variables outputted from the 'mntr' command Zookeeper Admin.

If in Zookeper, the Prometheus Metric provider is enabled, instead use the prometheus input plugin. By default, the Prometheus metrics are exposed at http://<ip>:7000/metrics URL. Using the prometheus input plugin provides a native solution to read and process Prometheus metrics, while this plugin is specific to using mntr to collect the Java Properties format.

Global configuration options

In addition to the plugin-specific configuration settings, plugins support additional global and plugin configuration settings. These settings are used to modify metrics, tags, and field or create aliases and configure ordering, etc. See the CONFIGURATION.md for more details.

Configuration

# Reads 'mntr' stats from one or many zookeeper servers
[[inputs.zookeeper]]
  ## An array of address to gather stats about. Specify an ip or hostname
  ## with port. ie localhost:2181, 10.0.0.1:2181, etc.

  ## If no servers are specified, then localhost is used as the host.
  ## If no port is specified, 2181 is used
  servers = [":2181"]

  ## Timeout for metric collections from all servers.  Minimum timeout is "1s".
  # timeout = "5s"

  ## Float Parsing - the initial implementation forced any value unable to be
  ## parsed as an int to be a string. Setting this to "float" will attempt to
  ## parse float values as floats and not strings. This would break existing
  ## metrics and may cause issues if a value switches between a float and int.
  # parse_floats = "string"

  ## Optional TLS Config
  # enable_tls = false
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  ## If false, skip chain & host verification
  # insecure_skip_verify = true

Metrics

Exact field names are based on Zookeeper response and may vary between configuration, platform, and version.

• zookeeper
  • tags:
    • server
    • port
    • state
  • fields:
    • approximate_data_size (integer)
    • avg_latency (integer)
    • ephemerals_count (integer)
    • max_file_descriptor_count (integer)
    • max_latency (integer)
    • min_latency (integer)
    • num_alive_connections (integer)
    • open_file_descriptor_count (integer)
    • outstanding_requests (integer)
    • packets_received (integer)
    • packets_sent (integer)
    • version (string)
    • watch_count (integer)
    • znode_count (integer)
    • followers (integer, leader only)
    • synced_followers (integer, leader only)
    • pending_syncs (integer, leader only)

Debugging

If you have any issues please check the direct Zookeeper output using netcat:

$ echo mntr | nc localhost 2181
zk_version      3.4.9-3--1, built on Thu, 01 Jun 2017 16:26:44 -0700
zk_avg_latency  0
zk_max_latency  0
zk_min_latency  0
zk_packets_received     8
zk_packets_sent 7
zk_num_alive_connections        1
zk_outstanding_requests 0
zk_server_state standalone
zk_znode_count  129
zk_watch_count  0
zk_ephemerals_count     0
zk_approximate_data_size        10044
zk_open_file_descriptor_count   44
zk_max_file_descriptor_count    4096

Example Output

zookeeper,server=localhost,port=2181,state=standalone ephemerals_count=0i,approximate_data_size=10044i,open_file_descriptor_count=44i,max_latency=0i,packets_received=7i,outstanding_requests=0i,znode_count=129i,max_file_descriptor_count=4096i,version="3.4.9-3--1",avg_latency=0i,packets_sent=6i,num_alive_connections=1i,watch_count=0i,min_latency=0i 1522351112000000000

Documentation

Index

• type Zookeeper
  • func (z *Zookeeper) Gather(acc telegraf.Accumulator) error
  • func (*Zookeeper) SampleConfig() string

Types

type Zookeeper

type Zookeeper struct {
	Servers     []string        `toml:"servers"`
	Timeout     config.Duration `toml:"timeout"`
	ParseFloats string          `toml:"parse_floats"`

	EnableTLS bool `toml:"enable_tls"`
	EnableSSL bool `toml:"enable_ssl" deprecated:"1.7.0;use 'enable_tls' instead"`
	tlsint.ClientConfig
	// contains filtered or unexported fields
}

Zookeeper is a zookeeper plugin

func (*Zookeeper) Gather

func (z *Zookeeper) Gather(acc telegraf.Accumulator) error

Gather reads stats from all configured servers accumulates stats

func (*Zookeeper) SampleConfig

func (*Zookeeper) SampleConfig() string