Как сделать прочитать плагин collectd и write_kafka

Я хочу использовать kafka в качестве транспортного уровня для collectd . Я обнаружил, что есть плагин write_kafka для collectd , который отправляет все собранные метрики в тему kafka .

Я намеревался иметь несколько хосты как сборщики (работая как группы потребителей кафка ), чтобы вывести эти показатели за пределы темы, и поместите их в базу данных временных рядов ( infxdb или графит ).

collectd не имеет подключаемого модуля пользовательского ввода kafka . графит тоже не может читать кафку напрямую (я так думаю?). Какое программное обеспечение мне здесь не хватает?