0
Мне нужна простая проверка работоспособности для Apache Kafka. Я не хочу что-то большое и сложное, как Yahoo Kafka Manager, в основном я хочу проверить, является ли тема здоровой или нет, и если потребитель здоров.Основная функция проверки доступности кафки
Моя первая идея состояла в том, чтобы создать отдельную тему heart-beat и периодически отправлять и читать сообщения в/из нее, чтобы проверить доступность и задержку.
Вторая идея - прочитать все данные от Apache Zookeeper. Я могу получить все брокеры, разделы, темы и т. Д. От ZK, но я не знаю, сможет ли ZK предоставить что-то вроде информации об обнаружении сбоев.
Как я уже сказал, мне нужно что-то простое, что я могу использовать в своей программе проверки работоспособности приложения.