Kafka Продюсер и информация для потребителя

Question

Я пытаюсь создать инструмент, который может произвольно убить производителей и потребителей кафки, чтобы имитировать производственную среду. Есть ли способ найти активных производителей и потребителей в кластере kafka? Я хочу точно знать, какой поток, в котором хост действует как производитель или потребитель?

Answer 1

1. Я начал с получения I.P. по крайней мере, одного брокера кафки из кластера HDP.
2. Я проверил открытые соединения на брокере kafka на указанном порту (по умолчанию это 6667) и получил IP-адреса подключенных машин.
3. Используя свои IP-адреса, я узнал о процессах, связанных с брокером kafka.

Таким образом, я выяснил машины, которые являются производителями и потребителями кафки.