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/coordinator/base.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/coordinator/base.py')
| -rw-r--r-- | kafka/coordinator/base.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index bcd5889..6dd65dc 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -621,7 +621,7 @@ class HeartbeatTask(object): etd = time.time() + self._coordinator.config['retry_backoff_ms'] / 1000.0 self._client.schedule(self, etd) - +''' class GroupCoordinatorMetrics(object): def __init__(self, metrics, prefix, tags=None): self.metrics = metrics @@ -674,5 +674,4 @@ class GroupCoordinatorMetrics(object): "The number of seconds since the last controller heartbeat", tags), lastHeartbeat) """ - - +''' |