jnioche commented on issue #2210: PulsarSpout to use 
consumer.redeliverUnacknowledgedMessages() ?
URL: 
https://github.com/apache/incubator-pulsar/issues/2210#issuecomment-407734907
 
 
   > Probably it would even be better to use the method at #2211 so that we can 
precisely control the redelivery.
   
   We need both  _redeliverUnacknowledgedMessages()_ and #2211. The latter 
could be used for failed messages but we'd still need to keep track of the 
number of times it failed and a delay to apply. This won't help for messages 
which were being processed when the JVM died, which is why we need 
_redeliverUnacknowledgedMessages()_ at init time.
   
   > When subscribing the unacked messages are automatically re-delivered. 
   
   I'm confused. Do you mean that this is what it does even without using 
_redeliverUnacknowledgedMessages_? 
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to