Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
Novice
Description
Description
Support for delayed delivery pulsar messages using deliverAt
Proposed change
To add in the ability to set the delayed delivery of Pulsar messages by use of a header. This would use the deliverAt() functionality on the Pulsar producer which simply takes in the a timestamp in milliseconds based on UTC
Background:
Delayed delivery is a very useful feature within Pulsar that can be used for a number of scenarios where you want the message to be picked up at a particular time.
There is additionally a deliverAfter() method on the Pulsar producer where you can specify a time period instead of a specific time, but the implementation behind the scenes just turns this into a timestamp then uses that. As such just implementing deliverAt() provides enough flexibility to the clients.