From abdbc6ca2785a5646ee9dccf4f5ccf700da5f648 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Sun, 3 Jan 2016 16:10:40 -0800
Subject: [PATCH] Drop unused method from ConsumerCoordinator

---
 kafka/coordinator/consumer.py | 5 -----
 1 file changed, 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()