在运行一个项目时,我遇到了一些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 的基本原理以及导致此异常的幕后实际发生了什么。这是否意味着在重新平衡进行时发生了提交?为什么它被禁止并导致异常?