Update base.py

dpkp · Mar 19, 2024 · 984c996 · 984c996
1 parent 52c0d20
commit 984c996
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
@@ -632,7 +632,7 @@ def _on_join_leader(self, response):
 
         group_assignment = [
             (member_id, assignment if isinstance(assignment, bytes) else assignment.encode())
-            for member_id, assignment in group_assignment.items()
+            for member_id, assignment in iteritems(group_assignment)
         ]
 
         if self.config['api_version'] >= (2, 3, 0) and self.config['group_instance_id']: