需要识别闲置的卡夫卡消费者

Question

>我有 3 个具有相同组 ID 的 Spark 流使用者订阅了一个只有一个分区的 Kafka 主题。以便将一个分区分配给一个使用者，而其他使用者处于空闲状态。我们需要杀死闲置的消费者。我们正在将Spark与YARN一起使用。

如何识别空闲的消费者

kafka 是否有任何命令来检查哪个消费者处于空闲状态，或者我们是否可以实现相同的其他命令？

Answer 1

>kafka-consumer-groups --group name将显示组中的所有客户端以及分配了分区的客户端

虽然，如果其中一个使用者线程失败，备份进程并没有什么坏

处

Answer 2

试试这个 -

$ kafka-consumer-groups.sh --描述 --组 group_name --成员