我试图创建一个工具，可以杀死Kafka生产者和消费者随机，以模拟生产环境。有没有办法找到Kafka集群中活跃的生产者和消费者？我想确切地知道哪个线程在哪个主机中充当生产者还是消费者？
to94eoyn1#
我首先从hdp集群获取至少一个kafka代理的ip。我检查了kafka代理在其指定端口上打开的连接（默认为6667），并检索了连接机器的ip地址。使用它们的ip地址，我找到了连接到kafka代理的进程。因此，我找出了Kafka的生产者和消费者的机器。
1条答案
按热度按时间to94eoyn1#
我首先从hdp集群获取至少一个kafka代理的ip。
我检查了kafka代理在其指定端口上打开的连接（默认为6667），并检索了连接机器的ip地址。
使用它们的ip地址，我找到了连接到kafka代理的进程。
因此，我找出了Kafka的生产者和消费者的机器。