中间件 Kafka Kafka Apache Kafka 是一个分布式流处理平台,具备高吞吐、低延迟和持久化能力,是大数据管道和事件驱动架构的核心组件。本篇基于 franz-go 客户端,从安装配置、核心概念与命令行操作讲起,覆盖生产者、消费者与消费者组、偏移量提交与 MQ 选型,深入可靠性与幂等消费、顺序性与分区设计、重试死信与延迟消息、日志存储清理与集群高可用,最后汇总常见陷阱与最佳实践。 章节总览 安装与配置 核心概念 命令行操作 Go 客户端 franz-go 生产者 消费者与消费者组 偏移量与提交 MQ 选型与架构 可靠性与幂等消费 顺序性与分区设计 重试、死信与延迟消息 日志存储与清理策略 集群与高可用 常见陷阱与最佳实践