This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.2 by this push:
new fc2ccca KAFKA-7489: Fix ConnectDistributedTest system test to use
KafkaVersion (backport) (#7791)
fc2ccca is described below
commit fc2cccaff62392b6b6aec80d7b200a61503be94a
Author: Randall Hauch <[email protected]>
AuthorDate: Fri Dec 6 13:43:32 2019 -0600
KAFKA-7489: Fix ConnectDistributedTest system test to use KafkaVersion
(backport) (#7791)
Author: Randall Hauch <[email protected]>
Reviewers: Nigel Liang <[email protected]>, John Roesler
<[email protected]>
---
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()
