Skip to content
This repository was archived by the owner on Jan 24, 2024. It is now read-only.

[BUGFIX] Fix wrong broker cache with multiple listeners - #752

Merged
BewareMyPower merged 10 commits into
streamnative:masterfrom
wenbingshen:fixWrongBrokerCacheWithMultipleListeners
Sep 29, 2021
Merged

[BUGFIX] Fix wrong broker cache with multiple listeners#752
BewareMyPower merged 10 commits into
streamnative:masterfrom
wenbingshen:fixWrongBrokerCacheWithMultipleListeners

Conversation

@wenbingshen

Copy link
Copy Markdown
Contributor

Fixes #751

Motivation

The brokerCache in the current AdminManger does not distinguish the listener name, which causes the wrong broker metadata to be returned when there are multiple listenerNames

Modifications

Support multiple listenerNames in BrokerCache

@wenbingshen

Copy link
Copy Markdown
Contributor Author

@BewareMyPower @Demogorgon314 PTAL, Thanks.

Comment thread kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KopEventManager.java Outdated
Comment thread tests/src/test/java/io/streamnative/pulsar/handlers/kop/SaslPlainTestBase.java Outdated
@BewareMyPower

Copy link
Copy Markdown
Contributor

My review is done, PTAL.

@wenbingshen

Copy link
Copy Markdown
Contributor Author

My review is done, PTAL.

Thanks review. Addressed done. PTAL

Comment thread kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/EndPoint.java Outdated
@BewareMyPower
BewareMyPower merged commit c3bd3dd into streamnative:master Sep 29, 2021
BewareMyPower pushed a commit that referenced this pull request Sep 30, 2021
Fixes #751 

### Motivation
The brokerCache in the current AdminManger does not distinguish the listener name, which causes the wrong broker metadata to be returned when there are multiple listenerNames

### Modifications
Support multiple listenerNames in BrokerCache
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Kafka client can connect to a non-existing listener in advertisedListeners

2 participants