diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:10:40 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:10:40 -0800 |
| commit | abdbc6ca2785a5646ee9dccf4f5ccf700da5f648 (patch) | |
| tree | 79b00d52c2da229a07a2a15b3365197c0c48016c | |
| parent | 71af307f4e350a0e3ef21a6c986ebebb6717dc15 (diff) | |
| download | kafka-python-abdbc6ca2785a5646ee9dccf4f5ccf700da5f648.tar.gz | |
Drop unused method from ConsumerCoordinator
| -rw-r--r-- | kafka/coordinator/consumer.py | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 673cbaf..48d5e14 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -303,11 +303,6 @@ class ConsumerCoordinator(BaseCoordinator): time.sleep(self.config['retry_backoff_ms'] / 1000.0) - def ensure_partition_assignment(self): - """Ensure that we have a valid partition assignment from the coordinator.""" - if self._subscription.partitions_auto_assigned(): - self.ensure_active_group() - def close(self): try: self._maybe_auto_commit_offsets_sync() |