diff options
| -rw-r--r-- | kafka/coordinator/consumer.py | 3 |
1 files changed, 2 insertions, 1 deletions
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(): |