rdhabalia commented on issue #2260: ack message for atmost processing guaranty URL: https://github.com/apache/incubator-pulsar/pull/2260#issuecomment-408777850 > I thought we ack immediately after received messages. Umm.. [PulsarSource](https://github.com/apache/incubator-pulsar/blob/master/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java#L144) doesn't ack message immediately. So, in this case if PulsarSink doesn't ack message then PulsarSource's pulsar-consumer will never ack the message which will not move markDeletePosition of the cursor and broker restart will redeliver all the messages again.??
---------------------------------------------------------------- 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
