MINOR: Fix --enable-autocommit flag in verifiable consumer
The --enable-autocommit argument is a flag. It does not take a parameter. This was broken in
Reviewers: Ismael Juma Manikumar Reddy
@@ -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,
