Hi, Pulsar Community I opened a new PIP design PR. I am looking forward to your feedback.
https://github.com/apache/pulsar/pull/20776 Motivation Key_Shared has a mechanism called the "recently joined consumers" to keep message ordering. However, currently, it doesn't care about some corner cases. 1. [issue-1] The race condition in the "recently joined consumers", where consumers can be added before finishing reading and dispatching messages from ledgers. 2. [issue-2] Messages could be added to messagesToRedeliver without consumer-side operations such as unacknowledgement. We should care about these cases in Key_Shared subscription. Thanks, -- Yuri Mizushima yumiz...@yahoo-corp.jp
