kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix --enable-autocommit flag in verifiable consumer (#7743)
Date Sat, 23 Nov 2019 22:19:16 GMT
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 <jason@confluent.io>
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 <ismael@juma.me.uk>, Manikumar Reddy <manikumar.reddy@gmail.com>
---
 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,


Mime
View raw message