生产者

【背景】 订单履约链路：业务服务（K8s，4 副本）→ Kafka 3.5（3 broker，KRaft，"acks=all"，"min.insync.replicas=2"）→ 消费端写 MySQL 8.0 业务表。生产端配置："enab

«结论先行：producer 端 "buffer.memory" 是「应用侧第一个背压点」，它打满后 "send()" 不是抛异常，而是同步阻塞在 "RecordAccumulator.awaitAvailableMemory" 上，直到

一、现象与背景 去年 9 月，我们做租户隔离改造，把 "event-bus" topic（Kafka 3.5，KRaft 模式，3 broker，32 分区）的生产者从默认 round-robin 换成了自定义 Partitioner——按

«结论先行："linger.ms" 不是「给消息加多少毫秒延迟」的旋钮，而是批次（RecordBatch）的等待窗口；真正决定一条消息何时上路的，是 batch 队列里 batch 的三种刷盘触发路径——批满、超时、"flush()" 显式

一、现象：开了幂等，吞吐没涨，顺序却「看起来」更乱了 先给结论："enable.idempotence=true" 不是「加个开关就完事」，它会悄悄把 "max.in.flight.requests.per.connection" 从你写的