Kafka:终止一个消费者连接

Question

使用EMS可以查看到特定EMS服务器的所有连接，并终止任何不需要的连接。

据我所知，我在某个地方有一个不想要的进程，它订阅了我的Kafka主题，与我的进程具有相同的消费者名称。

因此，我的进程没有收到任何消息，我不知道这个"流氓"进程位于何处。

我可以运行任何命令来终止这种连接吗?

我正在运行Kafka 0.9

Answer 1

如果您使用Confluent Control Center，您可以看到每个消费者组和每个消费者组中的所有客户端。这可能有助于您识别"流氓"消费者。

否则，您可能不得不选择一个新的组id，这样其他客户端订阅的内容就无关紧要了(因为它将在另一个消费者组中)。

听起来你还应该配置一些安全和acl，这样流氓应用程序就不能认证和订阅他们不允许访问的主题。