【发布时间】：2016-11-06 18:08:56
【问题描述】：
我正在尝试创建一个可以随机杀死kafka生产者和消费者的工具，以模拟生产环境。有没有办法在 kafka 集群中找到活跃的生产者和消费者？我想确切地知道哪个主机中的哪个线程充当生产者或消费者？
【问题讨论】：
标签： apache-kafka jmx metrics
【发布时间】：2016-11-06 18:08:56
【问题描述】：
- 我从获取 I.P.来自 HDP 集群的至少一个 kafka 代理。
- 我在 kafka 代理的指定端口（默认为 6667）上检查了打开的连接，并检索了连接机器的 IP 地址。
- 使用他们的 IP 地址，我发现了连接到 kafka 代理的进程。
因此，我找出了 kafka 生产者和消费者的机器。
【讨论】：
-
这很有趣。我正在寻找做类似的事情。看看你用来实现这一点的一些代码会很有趣。
-
我现在没有这方面的代码，但是我在 Kafka 代理机器上使用 netstat 来确定哪些其他机器已经打开了与 6667 端口的连接，并使用生产者或消费者进程的端口