我想在Elasticsearch中放置kafka主题/分区滞后。
通过使用kafka挖洞和telegraf。
我已经在本地macbook中安装了kafka,burrow,telegraf和Elasticsearch。我知道在Telegraf中有一个洞穴输入插件。
telegraf洞穴插件:https://github.com/influxdata/telegraf/tree/master/plugins/inputs/burrow
请告诉我如何在Elasticsearch中设置Telegraf配置以收集主题/分区滞后。
谢谢。
最佳答案
如果要使Telegraf成为连接Burrow和Elasticsearch的数据管道。使用以下配置。
telegraf.conf
[[inputs.burrow]]
servers = ["http://burrowIp:8000"]
topics_exclude = [ "__consumer_offsets" ]
groups_exclude = ["console-*"]
[[outputs.elasticsearch]]
urls = [ "http://elasticsearchIp:9200" ]
timeout = "5s"
enable_sniffer = false
health_check_interval = "10s"
index_name = "burrow-%Y.%m.%d"
manage_template = false
此设置将在 Elasticsearch 上累积数据。