This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8e9869a777 MINOR: Run MessageFormatChangeTest in ZK mode only (#12395)
8e9869a777 is described below
commit 8e9869a77704f4206e80aefc284c3139645e637d
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
