[kafka] branch trunk updated: KAFKA-8291 : System test fix (#6637)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang 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 847957c  KAFKA-8291 : System test fix (#6637)
847957c is described below

commit 847957cbea48d404a4090d5c35ea41c3aca820c2
Author: Boyang Chen <bo...@confluent.io>
AuthorDate: Thu Apr 25 14:16:34 2019 -0700

    KAFKA-8291 : System test fix (#6637)
    
    As titled, this PR changed the default reset policy to latest accidentally for system tests, which in fact was earliest.
    
    Reviewers: Guozhang Wang <wa...@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 b9aa6a7..532c59f 100644
--- a/tests/kafkatest/services/verifiable_consumer.py
+++ b/tests/kafkatest/services/verifiable_consumer.py
@@ -168,7 +168,7 @@ class VerifiableConsumer(KafkaPathResolverMixin, VerifiableClientMixin, Backgrou
                  max_messages=-1, session_timeout_sec=30, enable_autocommit=False,
                  assignment_strategy="org.apache.kafka.clients.consumer.RangeAssignor",
                  version=DEV_BRANCH, stop_timeout_sec=30, log_level="INFO", jaas_override_variables=None,
-                 on_record_consumed=None, reset_policy="latest", verify_offsets=True):
+                 on_record_consumed=None, reset_policy="earliest", verify_offsets=True):
         """
         :param jaas_override_variables: A dict of variables to be used in the jaas.conf template file
         """