This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.3 by this push:
new 1b52eeafe9 MINOR: Run MessageFormatChangeTest in ZK mode only (#12395)
1b52eeafe9 is described below
commit 1b52eeafe98620650492058f0898c54017bfefed
Author: Alyssa Huang <[email protected]>
AuthorDate: Tue Jul 12 23:46:04 2022 -0700
MINOR: Run MessageFormatChangeTest in ZK mode only (#12395)
KRaft mode will not support writing messages with an older message format
(2.8) since the min supported IBP is 3.0 for KRaft. Testing support for reading
older message formats will be covered by
https://issues.apache.org/jira/browse/KAFKA-14056.
Reviewers: David Jacot <[email protected]>
---
tests/kafkatest/tests/client/message_format_change_test.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/tests/kafkatest/tests/client/message_format_change_test.py
b/tests/kafkatest/tests/client/message_format_change_test.py
index cb6cf72d22..b65ef24704 100644
--- a/tests/kafkatest/tests/client/message_format_change_test.py
+++ b/tests/kafkatest/tests/client/message_format_change_test.py
@@ -57,9 +57,9 @@ class MessageFormatChangeTest(ProduceConsumeValidateTest):
err_msg="Producer did not produce all messages in reasonable
amount of time"))
@cluster(num_nodes=12)
- @matrix(producer_version=[str(DEV_BRANCH)],
consumer_version=[str(DEV_BRANCH)], metadata_quorum=quorum.all_non_upgrade)
- @matrix(producer_version=[str(LATEST_0_10)],
consumer_version=[str(LATEST_0_10)], metadata_quorum=quorum.all_non_upgrade)
- @matrix(producer_version=[str(LATEST_0_9)],
consumer_version=[str(LATEST_0_9)], metadata_quorum=quorum.all_non_upgrade)
+ @matrix(producer_version=[str(DEV_BRANCH)],
consumer_version=[str(DEV_BRANCH)], metadata_quorum=[quorum.zk])
+ @matrix(producer_version=[str(LATEST_0_10)],
consumer_version=[str(LATEST_0_10)], metadata_quorum=[quorum.zk])
+ @matrix(producer_version=[str(LATEST_0_9)],
consumer_version=[str(LATEST_0_9)], metadata_quorum=[quorum.zk])
def test_compatibility(self, producer_version, consumer_version,
metadata_quorum=quorum.zk):
""" This tests performs the following checks:
The workload is a mix of 0.9.x, 0.10.x and 0.11.x producers and
consumers
