We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9ae99af commit 23f9daeCopy full SHA for 23f9dae
1 file changed
kafka/coordinator/base.py
@@ -702,10 +702,6 @@ def _on_join_leader(self, response):
702
group_assignment = self._perform_assignment(response.leader_id,
703
response.group_protocol,
704
members)
705
- for member_id, assignment in group_assignment.items():
706
- if not isinstance(assignment, bytes):
707
- group_assignment[member_id] = assignment.encode()
708
-
709
except Exception as e:
710
return Future().failure(e)
711
0 commit comments