You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2018/07/25 12:18:12 UTC

[GitHub] jnioche commented on issue #2210: PulsarSpout to use consumer.redeliverUnacknowledgedMessages() ?

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:
users@infra.apache.org


With regards,
Apache Git Services