事件驱动架构：Event Sourcing、CQRS 与 Saga 模式
事件驱动架构核心模式：事件溯源 Event Sourcing、命令查询职责分离 CQRS、Outbox 模式、Saga 编排与协调，以及与 Kafka 微服务集成的完整实践
posts
Kafka 消息队列专题
Kafka 企业级实践: 从核心概念到流处理，从集群架构到 Java 客户端
Kafka 运维监控与故障恢复：JMX 指标、Lag 监控与分区重分配
Kafka 生产集群运维：JMX 核心指标、Consumer Lag 监控告警、分区重分配、Broker 扩缩容与数据恢复
Kafka 详解：分布式日志系统、ISR 与一致性保证
Kafka 核心架构：Broker/Topic/Partition/Replica/ISR、一致性保证、与 RabbitMQ 设计差异
Kafka 生产者与消费者实战：批量发送、ACK 策略与 Consumer Group
Kafka 客户端编程核心：Producer 批量发送与幂等性、Consumer Group 分区分配、Rebalance 与位移提交
Kafka 安全指南：SASL、SSL 与 ACL
Kafka 安全加固：SASL/SCRAM/GSSAPI 认证、SSL/TLS 加密传输、ACL 权限控制
Kafka vs RabbitMQ vs Redis Streams：消息队列选型完全指南
Kafka、RabbitMQ、Redis Streams 三大消息队列的 12 维度深度对比、吞吐量/延迟基准与 8 场景选型决策树
Kafka Streams 与 KSQL 流处理实战：窗口、Join 与状态存储
Kafka Streams DSL/Processor API、窗口操作、Join、状态存储、KSQL 查询与实时流处理实战
Kafka Connect 与 CDC 集成实战：Debezium、Schema Registry 与数据同步
Kafka Connect Source/Sink Connector、Debezium CDC 监听数据库变更、Schema Registry 与 Avro/Protobuf/JSON Schema
Go + Kafka 客户端实战：Sarama、Segmentio 与 Consumer Group
Go 开发 Kafka 应用：Sarama 与 Segmentio kafka-go 客户端、Consumer Group、事务生产者、Go 微服务集成
08. Java Spring Kafka 实战
Spring Kafka 配置、@KafkaListener、并发消费者、事务与错误处理
07. Kafka Streams 流处理
Kafka Streams: KStream、KTable、窗口聚合与 Exactly-Once 语义
06. Kafka Connect 数据集成
Kafka Connect Source/Sink Connector、Debezium CDC、数据管道构建与 Kafka Connect 生产实践。
05. Kafka 集群与高可用架构
Kafka Broker 角色、Controller 选举机制、ISR 副本同步、Leader 故障转移与 KRaft 模式下的无 ZooKeeper 架构。
04. Topic 设计与分区策略
Kafka Topic 分区数设计、键分区顺序保证、Topic 命名规范与最佳实践，掌握高吞吐场景下的 Topic 规划方法论。
03. Kafka 消费者组与偏移量管理
Kafka 消费者: Consumer Group 机制、Rebalance、自动/手动提交偏移量
02. Kafka 生产者 API 与发送语义
Kafka 生产者: ACK 策略、重试机制、幂等性与事务消息保证
01. Kafka 核心概念与架构
Kafka 基础: Topic、Partition、Broker、偏移量与日志存储结构