首页 / 架构与设计

Kafka

相关文章： Kafka — 架构与设计.

Kafka · 2026/10/13 · 9 分钟阅读 · 217

Kafka 中的 Consumer Group 与 Rebalance 在 Spring Boot 中的应用

理解 Kafka 如何将分区分配给消费者组，何时发生 Rebalance 以及如何在 Spring Boot 应用中减少 Rebalance 的影响。

Kafka · 2026/10/12 · 9 分钟阅读 · 275

Kafka producer：acks、幂等性和批处理

配置 acks、enable.idempotence、batch.size 和 linger.ms 来确保 Kafka producer 不丢失消息、不重复发送并达到高吞吐量。

Kafka · 2026/10/12 · 10 分钟阅读 · 98

Saga pattern 与 Kafka 分布式事务：预订旅游套餐示例

使用 Spring Boot 和 Kafka 实现 Saga orchestration 模式。预订机票、酒店、支付，以及在某一步失败时自动补偿。

Kafka · 2026/10/12 · 8 分钟阅读 · 137

Schema Registry 和 Avro/Protobuf 在 Kafka 与 Spring Boot 中的应用

使用 Confluent Schema Registry 与 Avro 和 Protobuf 在 Spring Boot 3 中控制 Kafka 消息格式，并安全地演进 schema

Kafka · 2026/10/12 · 11 分钟阅读 · 158

事件溯源和 Kafka：保存事件而非状态

使用 Kafka 作为订单事件日志：记录不可变事件、通过重放重建状态、用 projection 构建读模型。附带应用前必知的限制。

Kafka · 2026/10/12 · 8 分钟阅读 · 312

使用 Debezium 和 Kafka 实现变更数据捕获

使用 Debezium 读取 PostgreSQL 的 WAL，将所有数据更改推送到 Kafka，通过 Spring Boot 消费，无需修改数据写入代码。

Kafka · 2026/10/12 · 9 分钟阅读 · 158

使用 Kafka 的 Outbox 模式：数据库写入时不丢失事件

同时写入数据库和发送 Kafka 很容易丢失事件。本文介绍如何用 Spring Boot 3 和 Kafka 实现 Outbox 模式，保证两边始终一致。

Kafka · 2026/10/12 · 9 分钟阅读 · 418

监控 Kafka：consumer lag 和需要跟踪的关键指标

什么是 consumer lag，如何通过 CLI、AdminClient 和 Micrometer 进行测量，应该监控的 broker/producer/consumer 指标以及如何设置合理的告警。

Kafka · 2026/10/11 · 10 分钟阅读 · 98

Kafka Partition Key设计：消息顺序与负载均衡

Kafka 如何根据 key 选择 partition，如何选择 key 以保持消息顺序同时避免热 partition，以及 Spring Boot 中常见的错误。

Kafka · 2026/10/11 · 8 分钟阅读 · 105

Kafka retry 和 dead letter topic 配合 Spring Kafka

在 Spring Boot 3 中为 Kafka consumer 配置 blocking 和 non-blocking 重试，将失败的消息推送到 dead letter topic 并编写测试验证。

Kafka · 2026/10/11 · 9 分钟阅读 · 93

Kafka中的消费者组和重新平衡：消费者停止的原因

重新平衡如何运作、为什么它导致消费者停止处理消息，以及通过poll配置、协作重新平衡和静态成员身份来最小化它的方法。

Kafka · 2026/10/06 · 7 分钟阅读 · 114

Kafka Producer：正确处理 acks、retry 和幂等性

了解 acks、retries 和幂等性如何配合，确保 producer 向 Kafka 发送数据时消息不丢失、不重复。

Kafka · 2026/10/05 · 6 分钟阅读 · 116

Kafka 基础：Topic、Partition 和 Offset

解释 Kafka 的三个核心概念——topic、partition、offset——附带 Spring Boot 的 producer/consumer 示例。