我想在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 上累积数据。

elasticsearch - 如何在Elasticsearch中设置Telegraf配置以收集kafka主题/分区滞后-LMLPHP

07-28 03:15