Skip to content

KAFKA-20348: Move ControllerRegistrationManager to server module#21854

Merged
mimaison merged 2 commits intoapache:trunkfrom
mimaison:kafka-20348
Mar 23, 2026
Merged

KAFKA-20348: Move ControllerRegistrationManager to server module#21854
mimaison merged 2 commits intoapache:trunkfrom
mimaison:kafka-20348

Conversation

@mimaison
Copy link
Member

@mimaison mimaison commented Mar 23, 2026

We can't move ControllerRegistrationManagerTest yet due to dependencies
on KafkaConfig.

@github-actions github-actions bot added the core Kafka Broker label Mar 23, 2026
Copy link
Contributor

@clolov clolov left a comment

Choose a reason for hiding this comment

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

If the tests pass then this looks good to me 😊

logger.info("Found registration for {} instead of our incarnation.", curRegistration.incarnationId());
registeredInLog = false;
} else {
logger.info("Our registration has been persisted to the metadata logger.");
Copy link
Contributor

Choose a reason for hiding this comment

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

Nit: This used to be

...persisted to the metadata log.")

Copy link
Member Author

Choose a reason for hiding this comment

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

Haha good catch!
That's why you should use the IDE rename feature instead of doing replace all from the CLI


// Create the registration manager, which handles sending KIP-919 controller registrations.
registrationManager = new ControllerRegistrationManager(config.nodeId,
clusterId,
Copy link
Contributor

Choose a reason for hiding this comment

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

Nice catch!

@mimaison mimaison merged commit a3fae9c into apache:trunk Mar 23, 2026
22 checks passed
@mimaison mimaison deleted the kafka-20348 branch March 23, 2026 20:10
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

core Kafka Broker

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants