You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2017/12/06 02:51:02 UTC

[GitHub] lovelle opened a new pull request #942: Bugfix: duplicate messages for PartitionedConsumers.

lovelle opened a new pull request #942: Bugfix: duplicate messages for PartitionedConsumers.
URL: https://github.com/apache/incubator-pulsar/pull/942
 
 
   __Description:__
   
   When UnAckedMessageTracker is active and consumer is not
   on receive call, all messages which were redelivered will be duplicated on
   incomingMessages queue.
   
   __Changes:__
   
   * Implement `UnackMessageTracker` at PartitionedConsumerImpl level.
   * Removes break on `removeExpiredMessagesFromQueue` in order to filter all messages.
   * Fix context of `incomingMessages` on redelivery.
   
   This was tested under our stage environment and seems to fix duplicated
   messages. Also, this fix is not intended to be merged as is, it's just
   my attempt to solve this issue, please any feedback will be great!

----------------------------------------------------------------
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