我正在使用Kafka 1.0.0并使用以下命令检查Kafka Offset .
kafka-consumer-groups.sh --bootstrap-server <<bootstrap server>> --describe --group <<consumergroup>>
我将非常感谢您对以下Kafka消费者抵消问题的反馈:
- 如果我的消费者已关闭,我该如何检查消费者偏差?由于上面的命令显示以下消息:
Consumer group <<consumer group>> does not exist or is re-balancing
- 当消费者关闭时,如何重置消费者抵消?