KAFKA-1811 Ensuring registered broker host:port is unique#168
KAFKA-1811 Ensuring registered broker host:port is unique#168eribeiro wants to merge 1 commit intoapache:trunkfrom eribeiro:KAFKA-1811
Conversation
|
kafka-trunk-git-pr #275 FAILURE |
|
kafka-trunk-git-pr #276 SUCCESS |
|
kafka-trunk-git-pr #608 FAILURE |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
This has been somewhat addressed by #4897. The JIRA has been closed so I will close this PR. Please, reopen it if it is still relevant. |
The issue happening across brokers could also happen between cleaner/merger thread. To avoid this, load classes as part of the configure, so when jooq context is returned schema root is loaded.
Adds a ZKLock recipe implementation to guarantee that the host:port pair is unique among the brokers registered on ZooKeeper.