1

在运行一个项目时,我遇到了一些RebalanceInProgressException每周发生一次或两次并导致消费者失败的情况。这是消息:

org.apache.kafka.common.errors.RebalanceInProgressException: 
Offset commit cannot be completed since the consumer member's generation is 
already stale, meaning it has already participated another rebalance and got
a new generation. You can try completing the rebalance
by calling poll() and then retry commit again

我想了解 Kafka 的基本原理以及导致此异常的幕后实际发生了什么。这是否意味着在重新平衡进行时发生了提交?为什么它被禁止并导致异常?

4

0 回答 0