diff --git a/kafka/consumer/subscription_state.py b/kafka/consumer/subscription_state.py
index fa09a060b..d054fc559 100644
--- 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