Соединение Java-клиента Kafka, проблема с сервером

Question

Я использую клиент Kafka Java, и иногда у нас бывает время простоя на Kafka Server. Нам нужно отправить в систему мониторинга сигнал тревоги о том, что сервер Kafka недоступен.

Каков наилучший способ проверки работоспособности сервера Kafka из Java-клиента?

Answer 1

Если ваша главная цель - проверить, работает ли кластер брокера Kafka, вы можете проверить с помощью

1. Доступен порт брокера Kafka
2. Наблюдайте за узлом Zookeeper для брокера, чтобы проверить, доступен ли любой дочерний узел.