我试图检查订阅了一个名为“foo”的主题的消费者。我没有Kafka的消费信息。我们是否可以用它来检查“foo”主题的消费者数量？
omhiaaxx1#
对于用户组成员，您可以始终列出使用 kafka-consumer-groups 脚本，例如。https://kafka.apache.org/documentation/#basic_ops_consumer_lag但在一般情况下，对于不是cg成员的消费者来说，这并不是很可能的——基本上每个消费者都会定期发送一条消息 FetchRequest 给经纪人，经纪人只是回复。对于这一点来说，非常过分的解决方案是捕获代理和客户机之间的通信量并解析有效负载（使用http://kafka.apache.org/protocol.html#the_messages_fetch). 每个获取请求都包含 client-id ，可用于识别消费者。
kafka-consumer-groups
FetchRequest
client-id
1条答案
按热度按时间omhiaaxx1#
对于用户组成员，您可以始终列出使用
kafka-consumer-groups脚本，例如。https://kafka.apache.org/documentation/#basic_ops_consumer_lag但在一般情况下，对于不是cg成员的消费者来说，这并不是很可能的——基本上每个消费者都会定期发送一条消息
FetchRequest给经纪人，经纪人只是回复。对于这一点来说，非常过分的解决方案是捕获代理和客户机之间的通信量并解析有效负载（使用http://kafka.apache.org/protocol.html#the_messages_fetch). 每个获取请求都包含
client-id，可用于识别消费者。