diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-03-17 11:21:48 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-03-17 11:21:48 -0700 |
| commit | f83e27168fe5f0d5c71b962b8788e05640ea8e2b (patch) | |
| tree | e748f7c17f7324c71c90b2443a1f694510b3bcfb /kafka/consumer | |
| parent | 2dc8c3cffaeb35cdc36353847b271b845a134cb7 (diff) | |
| download | kafka-python-f83e27168fe5f0d5c71b962b8788e05640ea8e2b.tar.gz | |
Add default_offset_commit_callback to KafkaConsumer DEFAULT_CONFIGS
Diffstat (limited to 'kafka/consumer')
| -rw-r--r-- | kafka/consumer/group.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 32a4a49..f646e05 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -149,6 +149,7 @@ class KafkaConsumer(six.Iterator): 'auto_offset_reset': 'latest', 'enable_auto_commit': True, 'auto_commit_interval_ms': 5000, + 'default_offset_commit_callback': lambda offsets, response: True, 'check_crcs': True, 'metadata_max_age_ms': 5 * 60 * 1000, 'partition_assignment_strategy': (RangePartitionAssignor, RoundRobinPartitionAssignor), |