spring-boot - 重新平衡时的Kafka消费者

据我所知，在重新平衡时，主题分区将被撤销并重新分配给消费者组的消费者。有时在处理消息时我们会收到错误“此服务器不是该主题分区的领导者”

对于Producer，我们可以使用事务，重试重发消息，不用担心重复。但是当我们从消费者那里确认这条消息时，它会显示错误。有什么解决方案可以解决消费者中的这个问题吗？我们可以像 Producer 一样重试 ack。

谢谢

标签： spring-bootapache-kafkakafka-consumer-api