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

[KRaft]: Allow KafkaRoller directly connect to controllers #9692

Open
tinaselenge opened this issue Feb 15, 2024 · 4 comments · May be fixed by #10016
Open

[KRaft]: Allow KafkaRoller directly connect to controllers #9692

tinaselenge opened this issue Feb 15, 2024 · 4 comments · May be fixed by #10016

Comments

@tinaselenge
Copy link
Contributor

Related problem

KafkaRoller currently connects to the controller via brokers to get the quorum health information.

Suggested solution

With Strimzi supporting Kafka 3.7 which includes KIP 919, we should create a service for controller pods and make KafkaRoller connect to it for quorum information.

Alternatives

No response

Additional context

No response

@scholzj
Copy link
Member

scholzj commented Feb 22, 2024

Triaged on the community call on 22.2.2024: This should be done once Kafka 3.7 is released. Unless the implementation is trivial, it should have a proposal.

@tinaselenge tinaselenge self-assigned this Mar 14, 2024
@tinaselenge tinaselenge linked a pull request Apr 23, 2024 that will close this issue
8 tasks
@tinaselenge
Copy link
Contributor Author

tinaselenge commented May 14, 2024

When working on this, I discovered that we need to configure controller listeners with hostnames in order for Admin client to bootstrap. This was not clearly stated in the KIP, so I raised an upstream issue.

Reconfiguring the controller listeners do work and allows the operator to talk to the controller directly. I have raised a draft PR #10016. However, this causes controller pods to crash once or twice until the DNS is updated. When a pod gets terminated, pod's IP address changes and the DNS needs to be updated to resolve the hostnames to the new IP address.

@tinaselenge
Copy link
Contributor Author

This issue is blocked until https://issues.apache.org/jira/browse/KAFKA-16781 is completed.

@ppatierno
Copy link
Member

@tinaselenge take into account that implementing KAFKA-16781 could affect migration as well, because right now the advertised.listeners for a controller node is not allowed in Kafka and it's not applied by the cluster operator. After KAFKA-16781 we should configure advertised.listeners during the migration as well I guess.

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

Successfully merging a pull request may close this issue.

3 participants