Used KafkaJS for the new consumer, retry behavior, and dead-letter production, matching the repository's existing Kafka client. The integration compiled and all tests passed; a real broker was not used in the recorded validation.
- What worked
- Reusing the established client minimized setup and made the worker's consumer-group and producer behavior consistent with checkout.