Thank you for reading this post, don't forget to subscribe!

Отоб­ра­же­ние актив­ных бро­ке­ров Kafka с помо­щью ути­лит команд­ной строки.

Я буду исполь­зо­вать скрипт команд­ной стро­ки kafka-broker-api-versions.sh, кото­рый явля­ет­ся частью рели­за Kafka.

$ cd kafka

Выпол­ни­те его, что­бы извлечь теку­щий спи­сок брокеров.

$ bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092 | awk '/^[a-z]/ {print $1}'

Вывод:

kafka2.example.org:9092
kafka3.example.org:9092
kafka1.example.org:9092

Полу­че­ние и отоб­ра­же­ние инфор­ма­ции о вер­сии брокера.

$ bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092