This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new e057d61 MINOR: Fix --enable-autocommit flag in verifiable consumer
(#7743)
e057d61 is described below
commit e057d610502a1588e3436a53aedfaaad5126d7d5
Author: Jason Gustafson <[email protected]>
AuthorDate: Sat Nov 23 14:18:42 2019 -0800
MINOR: Fix --enable-autocommit flag in verifiable consumer (#7743)
The --enable-autocommit argument is a flag. It does not take a parameter.
This was broken in #7724.
Reviewers: Ismael Juma <[email protected]>, Manikumar Reddy
<[email protected]>
---
tests/kafkatest/services/verifiable_consumer.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/kafkatest/services/verifiable_consumer.py
b/tests/kafkatest/services/verifiable_consumer.py
index d4e873a..85083ba 100644
--- a/tests/kafkatest/services/verifiable_consumer.py
+++ b/tests/kafkatest/services/verifiable_consumer.py
@@ -310,7 +310,7 @@ class VerifiableConsumer(KafkaPathResolverMixin,
VerifiableClientMixin, Backgrou
cmd += " --assignment-strategy %s" % self.assignment_strategy
if self.enable_autocommit:
- cmd += " --enable-autocommit %s" % self.enable_autocommit
+ cmd += " --enable-autocommit "
cmd += " --reset-policy %s --group-id %s --topic %s --broker-list %s
--session-timeout %s" % \
(self.reset_policy, self.group_id, self.topic,
