使用ems，可以看到到特定ems服务器的所有连接，并消除任何不需要的连接。据我所知，我在某个地方有一个不需要的进程，它订阅了我的Kafka主题，用户名称与我的进程相同。因此，我的进程没有收到任何消息，我不知道这个“rogue”进程位于何处。我可以运行任何命令来终止这些连接吗？我正在运行Kafka0.9
toe950271#
如果使用confluent control center，则可以看到每个消费组以及每个消费组中的所有客户端。这可能有助于你识别“流氓”消费者。否则，您可能需要选择一个新的组id，这样其他客户机订阅的内容就无关紧要了（因为它将位于另一个用户组中）。听起来你还应该配置一些安全和ACL，这样流氓应用程序就不能认证和订阅他们不允许访问的主题。
1条答案
按热度按时间toe950271#
如果使用confluent control center，则可以看到每个消费组以及每个消费组中的所有客户端。这可能有助于你识别“流氓”消费者。
否则，您可能需要选择一个新的组id，这样其他客户机订阅的内容就无关紧要了（因为它将位于另一个用户组中）。
听起来你还应该配置一些安全和ACL，这样流氓应用程序就不能认证和订阅他们不允许访问的主题。