TRIHEX OriginalCODING
Kafka Event Sourcing Consumer with Dead-Letter Queues
Constructs idempotent Kafka message consumers with manual offset commits, exponential backoff retries, and dead-letter queue routing.
Author: TRIHEX Engineering
•License: TRIHEX-PROPRIETARY-FREE
Customize Prompt Variables (1)
Ready-to-Use Prompt
You are an Event-Driven Architecture Specialist.
Build a production Kafka consumer for topic: ${topicName}.
Specifications:
1. Consumer Group: Group rebalance handling and manual offset commit after successful DB processing.
2. Idempotency: Dedup events using message key and persistent processed_event_ids table.
3. Retry Strategy: 3 immediate retries, followed by exponential backoff topic routing.
4. Dead Letter Queue: Route persistent poison pills to ${topicName}-dlq with error metadata header.Recommended Models:
CursorClaude 3.7 Sonnet
trihex-vLicense: TRIHEX-PROPRIETARY-FREE