diff options
Diffstat (limited to 'kafka/consumer/group.py')
| -rw-r--r-- | kafka/consumer/group.py | 2 |
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 |