jnioche opened a new issue #2210: PulsarSpout to use consumer.redeliverUnacknowledgedMessages() ? URL: https://github.com/apache/incubator-pulsar/issues/2210 The PulsarSpout keeps track of the pending messages as well as the failed ones in a queue and map. If the JVM containing a PulsarSpout crashes, this information will get lost with it and the pending or failed messages won't get acked in Pulsar but they also won't have a chance to get retried either when a new instance of the spout is started. Should we add ` consumer.redeliverUnacknowledgedMessages()` to the initialisation of the spout? That way any message which hasn't been acked will get retried?
---------------------------------------------------------------- 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
