GitHub user shubham-Shole4ever created a discussion: Support for long running 
message consumer

**Is your feature request related to a problem? Please describe.**
The ackTimeout is set at the consumer level and is valid for all the messages 
that consumer handles. We have a case where the consumption of a message takes 
an unpredictable amount of time, ranging from 10 mins to couple hours. We also 
don't want to set the ackTimeout for the messages to be max possible (which 
could be half a day or more).
Can we have a feature where the consumer can send back a signal to the broker, 
acknowledging that its not failed but currently working on the received 
message, and the broker extends the ackTimeout for that message.

**Describe the solution you'd like**
A functionality which allows the consumer to notify the broker that it is 
working on the received message. The broker, on receiving this signal can 
extend the ackTimeout for that particular message (probably refreshing the 
ackTimeout)

**Describe alternatives you've considered**
Currently, there is no way to modify the ackTimeout for a particular message. 
The ackTimeout is set at the consumer level and cannot be modified for any 
message.


GitHub link: https://github.com/apache/pulsar/discussions/18456

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@pulsar.apache.org

Reply via email to