Skip to content

🟡 HIGH: Add Kafka error handling (DLQ, retries) #4

@GitAddRemote

Description

@GitAddRemote

Problem

Kafka integration lacks error handling:

  • No error handler for @KafkaListener
  • No dead letter queue
  • No retry logic

Solution

  1. Add DeadLetterPublishingRecoverer
  2. Configure retry with backoff
  3. Add error handler bean
  4. Update consumer to use error handler

Acceptance Criteria

  • DeadLetterPublishingRecoverer configured
  • Retry logic with backoff
  • DLT topic created automatically
  • Tests for error scenarios
  • Metrics for failed messages

Priority

🟡 High - Required for reliable event processing

Metadata

Metadata

Assignees

No one assigned

    Labels

    high-priorityHigh priority - important for productionkafkaKafka event streamingreliabilitySystem reliability and resilience

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions