KafkaJS Dead Letter Queue
KafkaJS plugin to handle message processing failures by forwarding problematic messages to a dead-letter queue.
Dead Letter Queues are message queues that can be produced to when a message on another queue cannot be processed successfully. Dead-letter queues are useful for debugging your application or messaging system because they let you isolate problematic messages to determine why their processing doesn't succeed.
WIP: This project is not ready for use as of yet
Usage
const Kafka = const Dlq = const kafka = ... const consumer = kafkaconst producer = kafka const topic = 'example-topic' const eachMessage = Dlq const run = async { await consumer await consumer await consumer}