Matthieu Jacquet

Hello, I think you can achieve that with unique-tag. https://infinitic.substack.com/i/52382438/unique-tag The feature isn't documented well at the moment but it works well. Regards

Hello, We are encountering the same behavior on our Pulsar cluster in 3.1. It's a topic with long retention time (90 days) with delayed message that are acknowledged once consumed....

We are using pulsar through Infinitic.io framework Here is the consumer code : https://github.com/infiniticio/infinitic/blob/v0.13.0/infinitic-transport-pulsar/src/main/kotlin/io/infinitic/pulsar/consumers/Consumer.kt The setup of topic is also done by the framework here: https://github.com/infiniticio/infinitic/blob/v0.13.0/infinitic-transport-pulsar/src/main/kotlin/io/infinitic/pulsar/admin/PulsarInfiniticAdmin.kt