framework
framework/kafka/index.md
medium
framework-kafka-index
Kafka(Spring Kafka 视角)使用约定 — 生产者可靠性/消费者手动 ack/消费幂等/错误处理四个独立决策点。Use when 配生产者保证不丢 / 配 @KafkaListener 手动 ack / 做消费幂等去重 / 设计重试与死信队列时。
子项索引
| 子项 | 一句话 |
|---|---|
| kafka-producer-config skill | Kafka 生产者可靠性配置 — acks=all 不丢、enable.idempotence 幂等、retries、批量,及 KafkaTemplate 发送回调 |
| kafka-consumer-config skill | Kafka 消费者配置 — @KafkaListener、手动 ack(关 auto.commit + ackMode MANUAL)、位移管理、并发、消费组 |
| kafka-idempotent-consumer skill | Kafka 消费幂等 — 至少一次语义下必须去重(业务唯一键 / 去重表 / Redis setnx),应对重平衡、重试、补偿导致的重复消费 |
| kafka-error-handling skill | Kafka 消费错误处理 — DefaultErrorHandler 重试、死信队列 DLQ、阻塞 vs 非阻塞重试、毒丸消息隔离 |
Kafka · 框架使用约定索引
四个独立决策点,按你正在做的事下钻:
| 你在做什么 | 进哪个 |
|---|---|
| 配生产者、保证消息不丢、发送回调处理 | producer-config |
| 写 @KafkaListener、关自动提交改手动 ack、设并发与消费组 | consumer-config |
| 至少一次语义下做消费去重、防重复消费 | idempotent-consumer |
| 消费失败重试、死信队列、隔离毒丸消息 | error-handling |