Struct DlqRouter 

pub struct DlqRouter { /* private fields */ }

Tracks nack counts and routes dead-lettered messages.

Implementations

impl DlqRouter

pub fn new(source_topic: &str, dlq_topic: &str, max_retries: u32) -> Self

Create a new DLQ router.

dlq_topic is the name of the topic where dead-lettered messages are sent. It must already exist in the TopicManager.

pub fn nack(&mut self, partition: u32, offset: u64) -> bool

Record a negative acknowledgement for a message.

Returns true if the message should be routed to the DLQ (max retries exceeded). The caller is responsible for calling DlqRouter::route_to_dlq with the actual message bytes.

pub fn route_to_dlq( &mut self, mgr: &mut TopicManager, partition: u32, offset: u64, value: &[u8], ) -> Result<u64>

Route a message to the DLQ topic.

Clears the nack counter for the given offset after routing.

pub fn nack_count(&self, partition: u32, offset: u64) -> u32

Returns the current nack count for a message.

pub fn dlq_topic(&self) -> &str

Returns the DLQ topic name.

pub fn source_topic(&self) -> &str

Returns the source topic name.

pub fn max_retries(&self) -> u32

Returns the maximum retries setting.