From f83e27168fe5f0d5c71b962b8788e05640ea8e2b Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 17 Mar 2016 11:21:48 -0700 Subject: Add default_offset_commit_callback to KafkaConsumer DEFAULT_CONFIGS --- kafka/consumer/group.py | 1 + 1 file changed, 1 insertion(+) (limited to 'kafka') 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), -- cgit v1.2.1