kafka-patterns
Installation
SKILL.md
Apache Kafka 消息队列
来源:https://kafka.apache.org/documentation/
Spring Kafka:https://docs.spring.io/spring-kafka/reference/
Capability Boundaries
✅ Strong Suits
- 生产者配置 — acks(retry/partition)/retries(batchSize/linger)/幂等
- 消费者配置 — auto-offset-reset/enable-auto-commit/manual commit
- 幂等性保证 — 生产者 enable.idempotence + acks=all + 消费者业务去重
- Spring Kafka — @KafkaListener / @RetryableTopic / @DltHandler
- DLT死信 — DefaultErrorHandler + DeadLetterPublishingRecoverer
- 顺序消息 — 同一Key发送到同一分区
- 事务消息 — @Transactional + KafkaTransactionManager