-
Notifications
You must be signed in to change notification settings - Fork 14k
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
Refactor integration and system tests to remove Zookeeper, add group protocol parameter #17581
Refactor integration and system tests to remove Zookeeper, add group protocol parameter #17581
Conversation
SslProducerSendTest did not need to be updated
@@ -66,7 +66,7 @@ class ListOffsetsIntegrationTest extends KafkaServerTestHarness { | |||
} | |||
|
|||
@ParameterizedTest | |||
@ValueSource(strings = Array("zk", "kraft")) | |||
@ValueSource(strings = Array("kraft")) | |||
def testListMaxTimestampWithEmptyLog(quorum: String): Unit = { |
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.
Isn't the proper change here to remove the quorum parameter entirely?
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.
I'd wondered that and wanted someone to raise the question.
I think it makes sense to remove it.
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.
Happy to oblige :)
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.
I have a question out to @cmccabe regarding his preference.
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.
TestInfoUtils
uses the parameters to determine if it isKraft()
, isZkMigrationTest()
, etc. Usages of those methods would need to be updated too.
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.
Yes, I'm sure, but wouldn't AK 4.0 have all of the ZK migration tests removed, and wouldn't all tests be ZK?
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.
There are some shenanigans done in the base test classes regarding the quorum
param. Until we remove the ZK bits from that test infra, I think we actually need the quorum
param :-/
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.
I approve of the use of "shenanigans" to describe this 👍
…ProtocolOnly_KAFKA_XXXXX
@chia7712—do you have any advice for the best way to arrange these changes for review? |
@mumrah—can you take a look at approach in this PR and let me know if it's correct? Thanks! |
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.
@kirktrue the approach in the ducktape tests seems fine to me.
You might consider doing the system test changes in a separate PR since this one has grown quite large.
@@ -66,7 +66,7 @@ class ListOffsetsIntegrationTest extends KafkaServerTestHarness { | |||
} | |||
|
|||
@ParameterizedTest | |||
@ValueSource(strings = Array("zk", "kraft")) | |||
@ValueSource(strings = Array("kraft")) | |||
def testListMaxTimestampWithEmptyLog(quorum: String): Unit = { |
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.
There are some shenanigans done in the base test classes regarding the quorum
param. Until we remove the ZK bits from that test infra, I think we actually need the quorum
param :-/
Your system test changes are a superset of the changes I made in https://github.com/apache/kafka/pull/17638/files (involves just removing explicit
My PR also removes |
Removing "zk" from the list of quorum values to test in the integration and system tests. This does not remove all occurrences as not all tests support KRaft.
Committer Checklist (excluded from commit message)