задачи:
Собирать в ELK инфо из топиков <key> <datetime>
<key> - это соответственно key из сообщения
<datetime> - это время попадания сообщения в кафку
Может есть готовый инструмент?
Logstash, input kafka
Спасмбо, посмотрю
посмотрел, все хорошо, только вот не увидел там как получить время получения сообщения :( Только key
они же есть в json? далее после инпута - filter для парсинга json и удаление всех ненужных полей
Обсуждают сегодня