[kafka] branch 2.1 updated: KAFKA-7489: Fix ConnectDistributedTest system test to use KafkaVersion (backport) (#7791)

[rh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rhauch pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.1 by this push:
     new 95689c9  KAFKA-7489: Fix ConnectDistributedTest system test to use KafkaVersion (backport) (#7791)
95689c9 is described below

commit 95689c9289f25d8050249910c63c9fa11d10bddb
Author: Randall Hauch <rh...@gmail.com>
AuthorDate: Fri Dec 6 13:43:32 2019 -0600

    KAFKA-7489: Fix ConnectDistributedTest system test to use KafkaVersion (backport) (#7791)
    
    Author: Randall Hauch <rh...@gmail.com>
    Reviewers: Nigel Liang <ni...@nigelliang.com>, John Roesler <jo...@confluent.io>
---
 tests/kafkatest/tests/connect/connect_distributed_test.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/kafkatest/tests/connect/connect_distributed_test.py b/tests/kafkatest/tests/connect/connect_distributed_test.py
index a27b54d..07cd3ce 100644
--- a/tests/kafkatest/tests/connect/connect_distributed_test.py
+++ b/tests/kafkatest/tests/connect/connect_distributed_test.py
@@ -516,7 +516,7 @@ class ConnectDistributedTest(Test):
         When Connect distributed starts up, it either creates internal topics (v0.10.1.0 and after) 
         or relies upon the broker to auto-create the topics (v0.10.0.x and before).
         """
-        self.setup_services(broker_version=broker_version, auto_create_topics=auto_create_topics, security_protocol=security_protocol)
+        self.setup_services(broker_version=KafkaVersion(broker_version), auto_create_topics=auto_create_topics, security_protocol=security_protocol)
         self.cc.set_configs(lambda node: self.render("connect-distributed.properties", node=node))
 
         self.cc.start()