Kafka 消费者状态显示“没有活跃成员”，尽管我看到我的消费者正在摄取日志

Question

我正在使用 kafka 静态分区将消费者分配给组示例： 我有一个

test-topic

，有 3 个分区，我手动让 Consumer1 连接到分区 0，consumer2 连接到分区 1，consumer3 连接到分区 2。

使用：

consumer.assign(TopicPartition(`test-topic`, 1))
consumer_configs = {'group.id': 'groupM'}

注意： 我的 3 个消费者有相同的 groupID

当我部署应用程序时，我可以看到消费者正在摄取数据并生成结果文件，偏移量正在移动，但我在消费者组命令中没有看到任何活跃成员

./kafka-consumer-groups.sh --bootstrap-server "localhost:9092" --describe --group groupM

我明白了

Consumer group 'groupM' has no active members.

我还能尝试什么？

我检查了消费者的日志，但没有看到重启，使用 kafka-cli 监控消费者状态（不成功）

Answer 1

那里没有使用

group.id

配置；当您使用消费者分配API时，没有消费者组。

只有使用了

.subscribe

，你才会有一个消费组。