我想用作kafka
的传输层collectd
。我发现有一个write_kafka
插件collectd
,它将所有收集到的指标发送到一个kafka
主题。
我的意图是让一些主机作为收集器(作为kafka
消费者群体)来获取主题之外的指标,并将它们放入时间序列数据库(influxdb
或graphite
)。
collectd
没有kafka
消费者输入插件。也graphite
不能kafka
直接读取(我想?)。我这里缺少什么软件?
答案1
以下是用 Python 编写的 InfluxDB 的 Kafka 消费者:https://github.com/mre/kafka-influxdb