Kafka Patterns (Spring Kafka)

Concrete implementations of the conventions in rules/infra.md: topic naming, manual commits, idempotent consumers, and dead letter topics.

When to Activate

• Adding a @KafkaListener consumer or a KafkaTemplate producer
• Designing a new topic or partition key
• Handling consumer failures without losing or duplicating messages
• Setting up a dead letter topic for a consumer group

Producer

@Service
public class OrderEventProducer {
    private final KafkaTemplate<String, OrderCancelledEvent> kafkaTemplate;