Hi,
I am trying to design a real-time application where message timeout can be
as low as a minute or two (message can get stale real-fast).

In the rare chance that the consumers lag too far behind in processing
messages from the broker, is there a concept of expired message queue in
Kafka?

I would like to know if a message has expired and then park it in some
topic till as such time that a service can dequeue, process it and/or
investigate it.

Thanks.

Best,
Krish

Reply via email to