[GitHub] sschepens opened a new issue #946: Message duplication on PartitionedConsumer redelivery

[GitBox <gi...@apache.org>]

sschepens opened a new issue #946: Message duplication on PartitionedConsumer redelivery
URL: https://github.com/apache/incubator-pulsar/issues/946
 
 
   When redelivery is activated, `ConsumerImpl` removes messages from its queue if they are present, but when using `PartitionedConsumerImpl` messages should not be in the internal `ConsumerImpl` queue but instead in the `PartitionedConsumerImpl` queue. These messages get redelivered but are never removed from the `PartitionedConsumerImpl` queue, this generates a lot of duplicate messages.
   
   I remember that `PartitionedConsumerImpl` used to have an `UnAckedMessageTracker` why was this removed?
   We need to fix the communication between `PartitionedConsumerImpl`  and `ConsumerImpl` on redelivery, simply adding an `UnAckedMessageTracker` on `PartitionedConsumerImpl` is not gonna cut it, when a message is received by `PartitionedConsumerImpl` it should stop being tracked by `ConsumerImpl` and instead be tracked by `PartitionedConsumerImpl`

----------------------------------------------------------------
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:
users@infra.apache.org


With regards,
Apache Git Services