我想使用kafka作为kafka的传输层。 我发现有一个用于write_kafka插件，它将所有收集的度量标准发送到kafka主题。
我的目的是让几个主机作为收集者（作为一个kafka消费者组织）来从这些主题中获取这些指标，并将它们放入时间序列数据库（ influxdb或graphite ）中。
collectd没有kafka消费者input插件。 graphite也不能直接读kafka （我想？）。 我在这里错过了哪些软件？
这里是用Python编写的InfluxDB的Kafka使用者： https ： //github.com/mre/kafka-influxdb