Kafka 内部原理 2026-09-30

Kafka Quotas：如何限制 Producer 和 Consumer 的流量

设置1MB/秒配额，验证吞吐量从32.77MB/秒精确降到1.03MB/秒，延迟暴涨33倍，机制是拖慢响应而非拒绝。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Kafka 应该监控哪些指标

用jstat -gc检查JVM健康度，汇总本系列验证过的LAG/ISR/controller状态等真实巡检命令。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Kafka 常见故障排查路径

汇总本系列验证过的三类真实故障现象(LAG持续上涨/单client延迟异常/操作短暂卡顿)，构建带数字依据的排查路径。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Schema Registry：消息结构如何演进

用Avro原生API验证兼容性规则：新增带default字段的schema能读老数据，不带default的会真实报SchemaResolutionError。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Avro、JSON、Protobuf 怎么选

真实对比JSON/Avro/Protobuf序列化体积和速度，Protobuf体积接近Avro但速度快6倍。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Kafka Connect：Source 和 Sink Connector 怎么工作

用FileStreamSource/Sink跑通一次真实的standalone Connect，验证文件到Kafka到文件的完整链路及运行时增量同步。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Kafka Streams：一条消息如何变成状态存储

真实编写运行一份Kafka Streams单词计数程序，验证flatMap+groupBy+count的完整拓扑处理链路。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Kafka Streams State Store：状态为什么也要写回 Kafka

查看Streams应用自动创建的changelog和repartition内部topic，理解本地状态的持久化备份机制。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Window、Join 和时间语义

验证同一个key跨越5秒窗口边界后计数真实独立重新开始，不会跨窗口累加。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

MirrorMaker 2：跨集群复制怎么做

真实起第二个独立集群，用MirrorMaker2验证跨集群复制的topic命名规则、内部状态topic和约3秒的复制延迟。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

多机房 Kafka：跨地域复制和故障切换

模拟主机房整体宕机，诚实讨论多机房复制方案真实的RPO窗口约等于MirrorMaker2的复制延迟。

Kafka 真实验证 动画演示

Kafka 内部原理 2026-09-30

Kafka 与 Redis Stream、RabbitMQ 的区别

对比消费组新成员加入的真实体验，Redis Stream零等待 vs Kafka rebalance真实观测到6.2秒停顿。

Kafka 真实验证 动画演示