Prompts-MCP 686 skills · ai / design / design-pattern / framework / fundamentals / habit / lang / tech-selection /mcp/sse
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

链接