From a7d9a8ac3687b6ea57bb19d1029bc20b9be05f8c Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Mon, 26 Jul 2021 14:09:47 -0700 Subject: [PATCH] MINOR: Remove older brokers from upgrade test (#11117) As of version 2.2.1 , Kafka Streams uses message headers and thus requires broker version 0.11.0 or newer. Reviewers: John Roesler , Ismael Juma , A. Sophie Blee-Goldman --- tests/kafkatest/tests/streams/streams_upgrade_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/kafkatest/tests/streams/streams_upgrade_test.py b/tests/kafkatest/tests/streams/streams_upgrade_test.py index d3fa1a381be..9c81d8f7ed3 100644 --- a/tests/kafkatest/tests/streams/streams_upgrade_test.py +++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py @@ -28,7 +28,8 @@ from kafkatest.version import LATEST_0_10_0, LATEST_0_10_1, LATEST_0_10_2, LATES LATEST_2_0, LATEST_2_1, LATEST_2_2, LATEST_2_3, LATEST_2_4, LATEST_2_5, LATEST_2_6, LATEST_2_7, DEV_BRANCH, DEV_VERSION, KafkaVersion # broker 0.10.0 is not compatible with newer Kafka Streams versions -broker_upgrade_versions = [str(LATEST_0_10_1), str(LATEST_0_10_2), str(LATEST_0_11_0), str(LATEST_1_0), str(LATEST_1_1), \ +# broker 0.10.1 and 0.10.2 do not support headers, as required by suppress() (since v2.2.1) +broker_upgrade_versions = [str(LATEST_0_11_0), str(LATEST_1_0), str(LATEST_1_1), \ str(LATEST_2_0), str(LATEST_2_1), str(LATEST_2_2), str(LATEST_2_3), \ str(LATEST_2_4), str(LATEST_2_5), str(LATEST_2_6), str(LATEST_2_7), str(DEV_BRANCH)]