Re: [DISCUSS] PIP-282: Change definition of the recently joined consumers position

[Yubiao Feng]

+1

Thanks
Yubiao Feng

On Tue, Jul 11, 2023 at 12:55 PM Yuri Mizushima 
wrote:

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

[DISCUSS] PIP-282: Change definition of the recently joined consumers position

[Yuri Mizushima]

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