From 1fabef18bf586be4e12f71c8a8b03639f5eb590a Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 2 Feb 2016 08:01:45 -0800 Subject: [PATCH] Fixup: _send_offset_commit_request future should succeed w/ True, not None --- kafka/coordinator/consumer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 263dac0..a393d7e 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -399,7 +399,8 @@ class ConsumerCoordinator(BaseCoordinator): assert all(map(lambda v: isinstance(v, OffsetAndMetadata), offsets.values())) if not offsets: - return Future().success(None) + log.debug('No offsets to commit') + return Future().success(True) if self.config['api_version'] >= (0, 8, 2): if self.coordinator_unknown():