Kafka生产者和消费者信息

Question

我正在尝试创建一个可以随机杀死kafka生产者和消费者的工具，以模拟生产环境。有没有办法在kafka集群中找到活跃的生产者和消费者？我想确切知道哪个主机在哪个线程中充当生产者或消费者？

Answer 1

1. 我从 I.P 开始。来自 HDP 集群的至少一个 kafka 代理。
2. 我检查了 kafka 代理在其指定端口（默认为 6667）上的打开连接，并检索了连接机器的 IP 地址。
3. 使用他们的 IP 地址，我发现了连接到 kafka 代理的进程。

至此，我搞清楚了kafka生产者和消费者的机器