From ef955155f89e9a665a4b636e4535d7b50fce869d Mon Sep 17 00:00:00 2001 From: Taras Date: Sun, 18 Mar 2018 15:56:47 +0200 Subject: Add codec validators to record parser and builder for all formats. Also removed `decorator` dependency on tests Fixes #1443 --- test/conftest.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'test/conftest.py') diff --git a/test/conftest.py b/test/conftest.py index 52ebfb4..dbc2378 100644 --- a/test/conftest.py +++ b/test/conftest.py @@ -3,7 +3,6 @@ from __future__ import absolute_import import inspect import pytest -from decorator import decorate from test.fixtures import KafkaFixture, ZookeeperFixture from test.testutil import kafka_version, random_string @@ -73,6 +72,7 @@ def kafka_consumer_factory(kafka_broker, topic, request): def factory(**kafka_consumer_params): params = {} if kafka_consumer_params is None else kafka_consumer_params.copy() params.setdefault('client_id', 'consumer_%s' % (request.node.name,)) + params.setdefault('auto_offset_reset', 'earliest') _consumer[0] = next(kafka_broker.get_consumers(cnt=1, topics=[topic], **params)) return _consumer[0] -- cgit v1.2.1