Проверьте, активен или нет брокер kafka в python

#python #apache-kafka

#python #apache-kafka

Вопрос:

Я работаю над Kafka на python, используя kafka-python. Я хочу знать, могу ли я получить следующую информацию о kafka broker в самом python, и если да, то как?

  1. Количество активных и неактивных брокеров Kafka с именем брокера

Комментарии:

1. У брокеров есть идентификаторы, а не имена, но что вы подразумеваете под «активным»? Потому что, если брокер отключен, он не будет известен остальной части кластера

2. @Onecricket, вы правы. Я просто хочу получить идентификатор брокера онлайн-брокера на python. т. Е. Я просто хочу, чтобы какой-нибудь метод проверял его на python.

3. Я бы посоветовал взглянуть на класс AdminClient в библиотеке confluent_kafka python, поскольку это то, что вы будете использовать с Java API