Tag: kafka
All the articles with the tag "kafka".
-
Kafka 性能内核:磁盘系统凭什么跑出内存级吞吐
Kafka 用最普通的磁盘却能跑出百万级吞吐,甚至快过内存系统。本篇逐一拆开性能内核四板斧:顺序写、页缓存(内存交给 OS 而非 JVM 堆)、零拷贝 sendfile、日志分段与稀疏索引,再叠加批量与压缩,最后讲清冷读、SSL、段过多等变慢场景与调优取舍。
-
Kafka Consumer 深挖:poll 循环、offset 提交与 rebalance,怎么做到不丢不重不卡顿
生产者篇讲了消息怎么写进去,这篇补齐另一半:怎么可靠高效地读出来。拆 poll 单线程循环与心跳、offset 提交四姿势与不丢不重时机、三个 poll 生死参数、分区分配 assignor、rebalance 生命周期与 Consumer Lag 诊断。
-
Kafka Producer 深挖:分区策略与 Sticky Partitioner 是怎么把延迟砍半的
一条消息进哪个分区,直接决定 Kafka 的吞吐、延迟与顺序性。本篇从发送攒批讲起,拆四种分区策略,讲透 Sticky Partitioner 为何把无 key 的 p99 延迟砍半,再谈 key 路由、扩分区陷阱、顺序性与热点隔离。
-
Kafka 核心原理精讲:从一条日志到分布式流平台,把关键机制与取舍讲透
Kafka 原理精讲:以『分布式提交日志』为主线,讲透 Partition、Offset、ISR、HW、分区容量决策、pull 模型取舍、交付语义与 dumb-broker 设计哲学,附 KRaft + Java 上手 demo、反模式清单与 7 张原理图。
-
异步与削峰:用消息队列把洪峰挡在核心路径外
同步链路在峰值流量下极易被打垮。本篇讲清削峰 vs 解耦、MQ 缓冲与令牌桶入口结合的削峰模式、消费侧背压(Consumer Lag / DLQ / pause-resume)、异步后的一致性权衡与幂等消费,以及哪些场景不该异步。