package
Version:
v0.0.0-...-0fce7b6
Opens a new window with list of versions in this module.
Published: Aug 26, 2019
License: MIT
Opens a new window with license information.
Imports: 13
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
README
¶
Telegraf Plugin: Burrow
Collect Kafka topic, consumer and partition status
via Burrow HTTP API.
Supported Burrow version: 1.x
Configuration
[[inputs.burrow]]
## Burrow API endpoints in format "schema://host:port".
## Default is "http://localhost:8000".
servers = ["http://localhost:8000"]
## Override Burrow API prefix.
## Useful when Burrow is behind reverse-proxy.
# api_prefix = "/v3/kafka"
## Maximum time to receive response.
# response_timeout = "5s"
## Limit per-server concurrent connections.
## Useful in case of large number of topics or consumer groups.
# concurrent_connections = 20
## Filter clusters, default is no filtering.
## Values can be specified as glob patterns.
# clusters_include = []
# clusters_exclude = []
## Filter consumer groups, default is no filtering.
## Values can be specified as glob patterns.
# groups_include = []
# groups_exclude = []
## Filter topics, default is no filtering.
## Values can be specified as glob patterns.
# topics_include = []
# topics_exclude = []
## Credentials for basic HTTP authentication.
# username = ""
# password = ""
## Optional SSL config
# ssl_ca = "/etc/telegraf/ca.pem"
# ssl_cert = "/etc/telegraf/cert.pem"
# ssl_key = "/etc/telegraf/key.pem"
# insecure_skip_verify = false
Group/Partition Status mappings
OK
= 1
NOT_FOUND
= 2
WARN
= 3
ERR
= 4
STOP
= 5
STALL
= 6
unknown value will be mapped to 0
Fields
-
burrow_group
(one event per each consumer group)
- status (string, see Partition Status mappings)
- status_code (int,
1..6
, see Partition status mappings)
- partition_count (int,
number of partitions
)
- offset (int64,
total offset of all partitions
)
- total_lag (int64,
totallag
)
- lag (int64,
maxlag.current_lag || 0
)
- timestamp (int64,
end.timestamp
)
-
burrow_partition
(one event per each topic partition)
- status (string, see Partition Status mappings)
- status_code (int,
1..6
, see Partition status mappings)
- lag (int64,
current_lag || 0
)
- offset (int64,
end.timestamp
)
- timestamp (int64,
end.timestamp
)
-
burrow_topic
(one event per topic offset)
-
burrow_group
- cluster (string)
- group (string)
-
burrow_partition
- cluster (string)
- group (string)
- topic (string)
- partition (int)
- owner (string)
-
burrow_topic
- cluster (string)
- topic (string)
- partition (int)
Documentation
¶
There is no documentation for this package.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.