У нас есть KafkaConsuer:
KafkaConsumer<String, XYZ> kafkaConsumer = new KafkaConsumer<>(props);
Мы ищем способ указать, в порядке ли KafkaConsumer и может ли он подключиться к своему серверу - или другими словами: считается живым или мертвым.
Из этой документации мы можем узнать, что
потребитель периодически отправляет тактовые импульсы на сервер.Если потребитель падает или не может отправлять тактовые импульсы в течение сеанса session.timeout.ms, то потребитель будет считаться мертвым, а его разделы будут переназначены
Мы искали какой-то метод вKafkaConsumer сообщил о своем статусе, но не нашел его.
Есть ли способ провести проверку пинга / состояния здоровья потребителя?