diff options
| -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() |