diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-10 00:25:54 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-10 08:57:52 -0800 |
| commit | bbd6444e85a3062224a977f1033da3f393110b87 (patch) | |
| tree | be3e0c9005971a3a1180078b53e6e394c9be86f4 /kafka/cluster.py | |
| parent | 35ed2e75dab2ba44b57f4e7183ebc020f3121124 (diff) | |
| download | kafka-python-bbd6444e85a3062224a977f1033da3f393110b87.tar.gz | |
ConsumerCoordinator cleanups
- default assignors to RoundRobinPartitionAssignor
- check offsets types in commit_offsets_* methods
- succeed future in _send_offset_commit_request when no offsets
- raise exception if no subscribed topics in group_protocols()
- fix _subscription typo in metadata listener callbacks
- short circuit if no partitions passed to fetch_committed_offsets
- line-wrap comments
- return future from commit_offsets_async
- return future value from commit_offsets_sync
- fix self._failed_request callback partial args
- comment out metrics class for now
Diffstat (limited to 'kafka/cluster.py')
0 files changed, 0 insertions, 0 deletions