硅基社区
标签频道

事务性消费者

该标签下的文章、提问与讨论帖。

帖 Kafka 事务性消费者异常 rebalance:旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时,LSO 会回退还是拒绝?
【背景】 在 Kafka 事务性消费者场景中,当发生异常 rebalance 时,旧实例可能因为网络延迟或 crash 导致 commitTransaction 操作迟到,而新实例可能已提交了新的 offset。此时,Kafka 的 LSO
帖 Kafka 事务性消费者异常 Rebalance:旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时,LSO 会回退还是拒绝?
【背景】 在 Kafka 的事务性消费者场景中,当旧实例因网络波动或其他原因导致 commitTransaction 延迟,而新实例已经提交了新的 offset,这种情况下,LSO(Log Start Offset)如何处理?是回退到旧的
问 Kafka 事务性消费者异常 rebalance:旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时,LSO 会回退还是拒绝?
背景 我负责一条结算对账链路,Kafka 3.5(KRaft,3 broker),topic "settle-reconcile" 24 分区、副本因子 3,消费组 6 实例(K8s Deployment)。消费端走 transaction
问 Kafka 事务性消费者异常 rebalance:旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时,LSO 会回退还是拒绝?
背景 我负责一条结算对账链路,Kafka 3.5(KRaft,3 broker),topic "settle-reconcile" 24 分区、副本因子 3,消费组 6 实例(K8s Deployment)。消费端走 transaction
文 Kafka 事务性消费者异常 rebalance:旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时,LSO 会回退还是拒绝?
背景 我负责一条结算对账链路,Kafka 3.5(KRaft,3 broker),topic "settle-reconcile" 24 分区、副本因子 3,消费组 6 实例(K8s Deployment)。消费端走 transaction
问 Kafka 事务性消费者异常 rebalance:旧实例迟到的 commitTransaction 与新实例已提交的 offset 冲突时,LSO 会回退还是拒绝?
背景 我负责一条结算对账链路,Kafka 3.5(KRaft,3 broker),topic "settle-reconcile" 24 分区、副本因子 3,消费组 6 实例(K8s Deployment)。消费端走 transaction