0

我想知道如果将新的消费者添加到组中,我们如何处理消费者组的重新平衡。由于它会自动重新平衡分区分配,因此在尝试处理批处理并提交偏移量时运行的现有消费者会失败。

处理重新平衡或知道重新平衡何时发生,我可以忽略数据处理和提交偏移作业,并要求消费者再次从提交的偏移量轮询消息。

4

0 回答 0