Я хочу написать скрипт, который рассчитывает общую задержку на потребителя / раздел. Я знаю общую команду.
bin / kafka-consumer-groups -bootstrap-server: 9092,: 9092,: 9092 - описать --group
Как лучше всего проанализировать данные и распечатать их для регистрации? Наряду с названием темы и задержкой потребителя я буду добавлять метку времени при каждом запуске этой команды. поэтому я могу отправлять данные в Elastic search и рассчитывать общую задержку по времени на одного потребителя.
Мы не хотим использовать инструменты kafka manager и burrow
Кафка версия 1.1.0
Спасибо