Fix offset fetch when partitions are manually assigned (dpkp#786)

dpkp · web-flow · commit ec286c9fb6a4 · 2016-08-01T16:30:03.000-07:00
diff --git a/kafka/consumer/subscription_state.py b/kafka/consumer/subscription_state.py
@@ -199,6 +199,7 @@ def assign_from_user(self, partitions):
             del self.assignment[tp]
 
         self.needs_partition_assignment = False
+        self.needs_fetch_committed_offsets = True
 
     def assign_from_subscribed(self, assignments):
         """Update the assignment to the specified partitions
