Skip to content
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

KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup #15192

Closed
wants to merge 1 commit into from

Conversation

cmccabe
Copy link
Contributor

@cmccabe cmccabe commented Jan 14, 2024

Some kcontroller dynamic configurations may fail to apply at startup. This happens because there is a race between registering the reconfigurables to the DynamicBrokerConfig class, and receiving the first update from the metadata publisher. We can fix this by registering the reconfigurables first. This seems to have been introduced by the "MINOR: Install ControllerServer metadata publishers sooner" change.

…startup

Some kcontroller dynamic configurations may fail to apply at startup. This happens because there is a race between registering the reconfigurables to the DynamicBrokerConfig class, and receiving the first update from the metadata publisher. We can fix this by registering the reconfigurables first. This seems to have been introduced by the "MINOR: Install ControllerServer metadata publishers sooner" change.
@cmccabe
Copy link
Contributor Author

cmccabe commented Jan 14, 2024

I included a test. It sometimes passes even when the fix is not present, because of the nature of the bug. Adding a Thread.sleep makes it consistently fail in the buggy version.

@cmccabe cmccabe added the kraft label Jan 16, 2024
Copy link
Contributor

@rondagostino rondagostino left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM assuming test passes -- thanks!

@cmccabe
Copy link
Contributor Author

cmccabe commented Jan 17, 2024

committed, thanks!

@cmccabe cmccabe closed this Jan 17, 2024
@cmccabe cmccabe deleted the KAFKA-16126 branch January 17, 2024 00:03
@divijvaidya
Copy link
Contributor

@divijvaidya
Copy link
Contributor

For completenss, the associated commit was merged to 3.6, 3.7 and trunk

3.6 -b743f6f
3.7 - b403683
trunk - 0015d0f

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
3 participants