From 82e75b960737b50456e862f127f857832b22624e Mon Sep 17 00:00:00 2001 From: Ewen Cheslack-Postava Date: Mon, 6 Feb 2017 13:53:22 -0800 Subject: [PATCH] MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH constant Author: Ewen Cheslack-Postava Reviewers: Matthias J. Sax , Guozhang Wang Closes #2508 from ewencp/minor-streams-compatibility-trunk-dev-branch --- tests/kafkatest/tests/streams/streams_broker_compatibility.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/kafkatest/tests/streams/streams_broker_compatibility.py b/tests/kafkatest/tests/streams/streams_broker_compatibility.py index 7c7a751ecbc..4a035a476d7 100644 --- a/tests/kafkatest/tests/streams/streams_broker_compatibility.py +++ b/tests/kafkatest/tests/streams/streams_broker_compatibility.py @@ -20,7 +20,7 @@ from kafkatest.services.kafka import KafkaService from kafkatest.services.streams import StreamsBrokerCompatibilityService from kafkatest.services.verifiable_consumer import VerifiableConsumer from kafkatest.services.zookeeper import ZookeeperService -from kafkatest.version import TRUNK, LATEST_0_10_1, LATEST_0_10_0, KafkaVersion +from kafkatest.version import DEV_BRANCH, LATEST_0_10_1, LATEST_0_10_0, KafkaVersion class StreamsBrokerCompatibility(Test): @@ -55,7 +55,7 @@ class StreamsBrokerCompatibility(Test): def setUp(self): self.zk.start() - @parametrize(broker_version=str(TRUNK)) + @parametrize(broker_version=str(DEV_BRANCH)) @parametrize(broker_version=str(LATEST_0_10_1)) def test_compatible_brokers(self, broker_version): self.kafka.set_version(KafkaVersion(broker_version))