|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- 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
|