[CAMEL-13841] Pulsar: Add the ability to manually acknowledge a message consumed from Pulsar

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.24.1
• Fix Version/s: 3.0.0.RC1, 3.0.0, 2.25.0
• Labels: pull-request-available
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Masa
• Created: 09/Aug/19 02:41
• Updated: 03/Mar/20 16:15
• Resolved: 13/Aug/19 04:23

Description

Pulsar messages are currently acknowledged immediately upon consumption, which could lead to lost messages if the application crashes or does not finish its unit of work. [Correction March 3, 2020 -- This is not correct. Pulsar messages are acknowledged after successful processing of the route, not immediately after consumption from the topic. Exceptions or errors on the route will correctly cause the message to remain unacknowledged.]

It would be desirable to add the ability to manually acknowledge a message consumed from Pulsar. The end user can decide when to acknowledge, or negative acknowledge a Pulsar message within the route. This will become a necessity when support for asynchronous processing of Pulsar messages is added.

Add a handle to the Pulsar consumer in a header in the Exchange so that the user can acknowledge the message at will similar to what was done for Kafka:

https://github.com/apache/camel/blob/camel-2.24.x/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaManualCommit.java

https://issues.apache.org/jira/browse/CAMEL-11933

Issue Links

• links to: GitHub Pull Request #3094
• links to: GitHub Pull Request #3347