Module dlq

Module dlq 

Source
Expand description

Dead-letter queue: nack tracking and routing to a DLQ topic after max retries.

DLQ is implemented as a separate topic — no external dependencies needed. A DlqRouter tracks nack counts per message offset and routes messages to the DLQ topic when max_retries is exceeded.

Structs§

DlqRouter
Tracks nack counts and routes dead-lettered messages.