分类频道
消息队列
该分类下的文章、提问与讨论帖。
一、现象与背景 去年 9 月,我们做租户隔离改造,把 "event-bus" topic(Kafka 3.5,KRaft 模式,3 broker,32 分区)的生产者从默认 round-robin 换成了自定义 Partitioner——按
«结论先行:"linger.ms" 不是「给消息加多少毫秒延迟」的旋钮,而是批次(RecordBatch)的等待窗口;真正决定一条消息何时上路的,是 batch 队列里 batch 的三种刷盘触发路径——批满、超时、"flush()" 显式
一、现象:交换机一断,ISR 就缩了,但没有任何人报错 去年 12 月,我们做 IDC 搬迁演练,把 6 台 Kafka 3.5 broker(KRaft 模式,3 个 rack × 2 台)的 rack-B 交换机直接拔线,模拟整机架断电
«结论先行:"acks=all" 只保证"broker 收到了才会回 ack",不保证"我下一批数据不依赖上一批的 ack 顺序"。当 "max.in.flight.requests.per.connection > 1" 且 "enabl