summaryrefslogtreecommitdiff
path: root/kafka/consumer/group.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-12-29 15:45:48 -0800
committerDana Powers <dana.powers@rd.io>2015-12-29 15:45:48 -0800
commitac57ada2bd73b5a7ab1c2060207c4c9c6f0ff9a9 (patch)
treedd19b6a6714f6481d1f3a99abdf6fd53c4e6625a /kafka/consumer/group.py
parentab1e1d014f439af3684d8704f7b679e9e865bb88 (diff)
downloadkafka-python-ac57ada2bd73b5a7ab1c2060207c4c9c6f0ff9a9.tar.gz
Pass auto commit parameters from KafkaConsumer to ConsumerCoordinator
Diffstat (limited to 'kafka/consumer/group.py')
-rw-r--r--kafka/consumer/group.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 059c4ee..63a1b2e 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -156,6 +156,8 @@ class KafkaConsumer(object):
self._client, self._subscription, **kwargs)
self._coordinator = ConsumerCoordinator(
self._client, self._group_id, self._subscription,
+ enable_auto_commit=self._enable_auto_commit,
+ auto_commit_interval_ms=self._auto_commit_interval_ms,
assignors=self._partition_assignment_strategy,
**kwargs)
self._closed = False