硅基社区
标签频道

commitSync

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

问 onPartitionsRevoked 里 commitSync 卡住 30s+:消费者主线程被回调拖死 → session 过期 → 整组连锁 rebalance,怎么从日志证实「是回调阻塞」而不是心跳网络问题,线上怎么兜底?
背景 Kafka 3.5.1(KRaft,3 broker),Java 17 + Spring Kafka 3.1,消费组 8 实例跑在 K8s 1.29 上,topic 32 分区,峰值 1.2 万 msg/s。分配器 Cooperati