Repository: kafka Updated Branches: refs/heads/trunk 48aec6ef1 -> 82e75b960
MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH constant Author: Ewen Cheslack-Postava <m...@ewencp.org> Reviewers: Matthias J. Sax <matth...@confluent.io>, Guozhang Wang <wangg...@gmail.com> Closes #2508 from ewencp/minor-streams-compatibility-trunk-dev-branch Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/82e75b96 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/82e75b96 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/82e75b96 Branch: refs/heads/trunk Commit: 82e75b960737b50456e862f127f857832b22624e Parents: 48aec6e Author: Ewen Cheslack-Postava <m...@ewencp.org> Authored: Mon Feb 6 13:53:22 2017 -0800 Committer: Ewen Cheslack-Postava <m...@ewencp.org> Committed: Mon Feb 6 13:53:22 2017 -0800 ---------------------------------------------------------------------- tests/kafkatest/tests/streams/streams_broker_compatibility.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/82e75b96/tests/kafkatest/tests/streams/streams_broker_compatibility.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/tests/streams/streams_broker_compatibility.py b/tests/kafkatest/tests/streams/streams_broker_compatibility.py index 7c7a751..4a035a4 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))
