Como ler de volta o plugin collectd e write_kafka

Question

Eu quero usar kafka como uma camada de transporte para collectd . Descobri que há um write_kafka plugin para collectd , que envia todas as métricas coletadas para um tópico kafka .

Minha intenção era ter alguns hosts como coletores (trabalhando como kafka grupos de consumidores) para remover essas métricas do tópico e colocá-las em um banco de dados de séries temporais ( influxdb ou graphite ).

collectd não tem um plug-in de entrada de consumidor kafka . graphite não pode ler kafka diretamente (eu acho?). Que parte do software estou faltando aqui?

    

Answer 1

Aqui está um consumidor Kafka para o InfluxDB escrito em Python: link