-
Notifications
You must be signed in to change notification settings - Fork 546
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
add kafka announcement only logic #1027
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
See my other comment in the container PR. ZookeeperAnnouncer needs to hold a general object, not a concrete ZookeeperServer
d2/src/main/java/com/linkedin/d2/balancer/servers/ConnectionManager.java
Show resolved
Hide resolved
|
gradle.properties
Outdated
@@ -1,4 +1,4 @@ | |||
version=29.58.11 | |||
version=29.58.12 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
better bump the minor version since we changed the public API of ZooKeeperAnnouncer (although it's backward compatible).
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please see my other comment about emitting SD event in container PR. It will need some changes in the callbacks of various markup/down in ZookeeperAnnouncer.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It will need some changes in the callbacks of various markup/down in ZookeeperAnnouncer.
How about directly change emitSDStatusActiveUpdateIntentAndWriteEvents
? We don't need to care about where it called
d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java
Show resolved
Hide resolved
This reverts commit bd54a98.
Summary
add kafka announcement only logic
More context and test could be found here:
https://github.com/linkedin-multiproduct/container/pull/1162