-
Notifications
You must be signed in to change notification settings - Fork 13
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
Upgrade to Kafka 3.8.0 #205
Conversation
assertThat(properties).containsEntry(KafkaConfig.AdvertisedListenersProp(), "PLAINTEXT://:9092,BROKER://:9093"); | ||
assertThat(properties).containsEntry(KafkaConfig.EarlyStartListenersProp(), "BROKER,CONTROLLER"); | ||
assertThat(properties).containsEntry(KafkaConfig.ListenerSecurityProtocolMapProp(), "BROKER:PLAINTEXT,CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT"); | ||
assertThat(properties).containsEntry("broker.id", "1"); |
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.
With constants now coming from so many different places, a mistake would be easy. Testing against the string gives us confidence that the production code is achieving the right config.
Signed-off-by: kwall <kwall@apache.org>
why: KAFKA-16207 removed symbol NON_ROUTABLE_ADDRESS so the reason for the substitution goes away Signed-off-by: kwall <kwall@apache.org>
@robobario could you review this too? |
Apache Kafka RC3 has several binding votes already, so in preparation for the Apache Kafka 3.8.0 release, I've undrafted this PR. |
Remove staging repo config.
@ozangunalp if you have chance, could you review please? |
@k-wall yes i have it on my list. But I'll need a couple of days. |
It looks good to me. I pushed a small change to pull the remaining config names. |
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.
lgtm
thanks @ozangunalp, could you add an approval so I can merge this. |
Changes to get compatibility with Kafka 3.8.0