Skip to content
This repository has been archived by the owner on Apr 1, 2024. It is now read-only.

ISSUE-13061: [BUG] Judgment criteria for reconnecting the producer #3343

Open
sijie opened this issue Dec 1, 2021 · 1 comment
Open

ISSUE-13061: [BUG] Judgment criteria for reconnecting the producer #3343

sijie opened this issue Dec 1, 2021 · 1 comment

Comments

@sijie
Copy link
Member

sijie commented Dec 1, 2021

Original Issue: apache#13061


Describe the bug
Related to this issue apache/pulsar-client-go#676

apache#11804, this PR rewrites the equals method of the Producer, resulting in that when different pulsar-client-go uses different port to reconnect, the old producer cannot be removed because the remoteAddress will be verified by equals:

if (producers.remove(producer.getProducerName(), producer)) {

apache#12846, this pr removes equals and will use hashcode for judgment. At this time, the
old producer cannot be removed.

The server does not allow different ports to connect to the same producerName. Does it assume that the previous connection will be disconnected first, and the new connection will be established? But the current pulsar-client-go seems to have some problems that the old connection did not handle.

@sijie sijie added the type/bug label Dec 1, 2021
@github-actions
Copy link

The issue had no activity for 30 days, mark with Stale label.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Projects
None yet
Development

No branches or pull requests

1 participant