diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-02-02 08:01:45 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-02-02 08:01:45 -0800 |
| commit | 1fabef18bf586be4e12f71c8a8b03639f5eb590a (patch) | |
| tree | 072aec3a65342619d5fc39c941caa3070def5494 | |
| parent | b60df8d1743b66a26eab0eb020626551c632f4f9 (diff) | |
| download | kafka-python-1fabef18bf586be4e12f71c8a8b03639f5eb590a.tar.gz | |
Fixup: _send_offset_commit_request future should succeed w/ True, not None
| -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(): |