-
Notifications
You must be signed in to change notification settings - Fork 1.6k
Support KRaft mode for EmbeddedKafkaBroker #2391
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
Comments
Feel free to contribute this feature. |
We are now on Kafka 3.3.1 so this can be implemented; contributions are welcome. |
If no one is working on it, I would like to give it a shot. |
@govi20 , no one as far as I am aware. Thank you for help proposal! |
Hi 👋🏽, sorry for hijacking the thread but I think this can be useful information. Testcontainers Kafka module version 1.18.0 offers support for Kraft mode. Look at this test |
I also found this apache/kafka#13375 which could be used as a basis for the changes needed here. |
I made some progress, but this is blocked by https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-15092 |
Unblocked; the necessary class is in server-common...-test.jar. |
Resolves #2391 * Kraft by default; polishing. * Fix typo.
Expected Behavior
The embedded Kafka broker should be able to run in KRaft mode.
Current Behavior
There is no option to run Kafka in KRaft mode nor to completely disable Zookeeper.
Context
KRaft mode becomes production ready from Kafka 3.3.0 and only available mode from Kafka 4+. So support for KRaft is becoming a requirement in 2023. But it is relevant just now for EmbeddedKafkaBroker because it is relative simplicity to run and minimize footprint by removing ZK.
The text was updated successfully, but these errors were encountered: