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 <boy...@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 <wangg...@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
"""
