无法描述Kafka Streams消费者组

Question

我想要实现的是确保我的Kafka流消费者没有滞后。

我有一个简单的Kafka流应用程序，以GlobalKTable的形式将一个主题具体化为存储。

当我尝试通过命令在Kafka上描述消费者时：

kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group my-application-id

我看不到任何结果。而且也没有错误。当我按以下方式列出所有消费者时：

kafka-consumer-groups --bootstrap-server localhost:9092 --describe --all-groups

我的应用程序使用者正确列出。

任何想法在哪里可以找到我无法描述的消费者正在发生的其他信息？（可以正确描述写给主题的任何其他Kafka流使用者。）

Answer 1

假设

kafka-consumer-groups \
    --bootstrap-server localhost:9092 \
    --describe \
    --all-groups

在您的消费者组中包含my-application-id，然后，如果

kafka-consumer-groups \
    --bootstrap-server localhost:9092 \
    --describe \
    --group my-application-id

根本不输出，这意味着到目前为止没有偏移量被提交。