Kafka消费者重新平衡:飞行中消息处理中止

Question

因此，当我们的应用程序向上/向下扩展时，Kafka消费者群体会重新平衡。

例如，当应用程序向下扩展时，其中一个使用者被终止，并且先前分配给该使用者的分区分布在组中的其他使用者中。当这个过程发生时，我的应用程序日志中有错误，说飞行中消息的处理已中止

我知道在消费者群体重新平衡时，整个消费者群体都会暂停(即(阅读任何新消息。但是，消费者在暂停之前阅读的信息会发生什么呢？我们能优雅地处理当前正在处理的消息吗？

提前感谢！

Answer 1

当消费者重新平衡发生时，已读取但未提交的消息将被忽略。消费者再平衡完成后，消费者将从上次提交的偏移量开始恢复消费，因此不会丢失任何消息。