This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new dcbc6c5 KAFKA-7489: Fix ConnectDistributedTest system test to use
KafkaVersion (backport) (#7791)
dcbc6c5 is described below
commit dcbc6c5cdbd0f2740cd3432d5c65e93a356ee26e
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 a6649d3..9ea0a8d 100644
--- a/tests/kafkatest/tests/connect/connect_distributed_test.py
+++ b/tests/kafkatest/tests/connect/connect_distributed_test.py
@@ -558,7 +558,7 @@ class ConnectDistributedTest(Test):
or relies upon the broker to auto-create the topics (v0.10.0.x and
before).
"""
self.CONNECT_PROTOCOL = connect_protocol
- 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()
