Kafka 事务性消费者异常 rebalance：旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时，LSO 会回退还是拒绝？

【背景】

在 Kafka 事务性消费者场景中，当发生异常 rebalance 时，旧实例可能因为网络延迟或 crash 导致 commitTransaction 操作迟到，而新实例可能已提交了新的 offset。此时，Kafka 的 LSO（Last Stable Offset）机制会如何处理这种冲突？是选择回退还是拒绝？

【常见分歧】

1. 回退：认为 LSO 会回退到旧实例最后一次 commitTransaction 的 offset，以保证数据一致性。
2. 拒绝：认为 LSO 会拒绝新实例的 offset 提交，以防止数据丢失或重复消费。

【我的倾向】

我倾向于认为 LSO 在这种场景下会拒绝新实例的 offset 提交。原因如下：

• 数据一致性优先：LSO 的核心目标是确保消费者不会漏读或重复读消息，因此在发生冲突时，拒绝新实例的 offset 提交可以避免数据丢失。
• 避免数据不一致：如果允许新实例提交 offset，可能会导致部分消息未被消费，从而引发数据不一致问题。

【想听大家在什么场景下怎么选】

在实际生产环境中，你们是如何处理这种冲突的？是否有过类似案例？欢迎分享你们的实践和经验！