You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by Yubiao Feng <yu...@streamnative.io.INVALID> on 2023/09/14 04:10:19 UTC
[DISCUSS] Cherry-pick the tool method `Servercnx.checkConnectionLiveness` into branch-2.10 and branch-2.11
Hi all
The PR https://github.com/apache/pulsar/pull/21155 fixes an issue in which
the producer sends messages timeout due to the inability to reconnect
successfully. The root cause is the client created a new connection to
reregister the producer after it assumed the old client was invalidated,
but at the same time, the broker assumed the old connection was still
validated, so the client got an error "Producer with name 'st-0-5' is
already connected to topic".
The fix in the PR https://github.com/apache/pulsar/pull/21155 tries to
start a new heartbeat after the broker receives different connections for
the same producer registration.
In this fix, the PR https://github.com/apache/pulsar/pull/21155 uses a tool
method `Servercnx.checkConnectionLiveness`( introduced in the PR
https://github.com/apache/pulsar/pull/20026).
I want to cherry-pick the tool method `Servercnx.checkConnectionLiveness`
into branch-2.10 and branch-2.11 along with the PR #21155
Thanks
Yubiao Feng
Re: [DISCUSS] Cherry-pick the tool method `Servercnx.checkConnectionLiveness` into branch-2.10 and branch-2.11
Posted by Yubiao Feng <yu...@streamnative.io.INVALID>.
Hi all
Cherry-picked.
Thanks
Yubiao Feng
On Thu, Sep 14, 2023 at 12:10 PM Yubiao Feng <yu...@streamnative.io>
wrote:
> Hi all
>
> The PR https://github.com/apache/pulsar/pull/21155 fixes an issue in
> which the producer sends messages timeout due to the inability to reconnect
> successfully. The root cause is the client created a new connection to
> reregister the producer after it assumed the old client was invalidated,
> but at the same time, the broker assumed the old connection was still
> validated, so the client got an error "Producer with name 'st-0-5' is
> already connected to topic".
>
> The fix in the PR https://github.com/apache/pulsar/pull/21155 tries to
> start a new heartbeat after the broker receives different connections for
> the same producer registration.
>
> In this fix, the PR https://github.com/apache/pulsar/pull/21155 uses a
> tool method `Servercnx.checkConnectionLiveness`( introduced in the PR
> https://github.com/apache/pulsar/pull/20026).
>
> I want to cherry-pick the tool method `Servercnx.checkConnectionLiveness`
> into branch-2.10 and branch-2.11 along with the PR #21155
>
>
> Thanks
> Yubiao Feng
>