shibd commented on issue #11979: URL: https://github.com/apache/pulsar/issues/11979#issuecomment-917815291
Currently, `unackedMessages` operates under the following scene: 1. Consumer use `Shard model` (SubscriptionType eq Shared / Key_Shared) 2. Consumer use `Individual ack`(consumer.acknowledge()) I try support all scene. But I found that this will have a great impact on the previous design. I think we can discuss it clearly before we start. Can be understand by PR: https://github.com/shibd/pulsar/pull/1/files -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org