Skip to content

Commit 2eab4ee

Browse files
committed
Fix StickyPartitionAssignor encode
1 parent 406f16c commit 2eab4ee

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/coordinator/assignors/sticky/sticky_assignor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -659,7 +659,7 @@ def _metadata(cls, topics, member_assignment_partitions, generation=-1):
659659
partitions_by_topic = defaultdict(list)
660660
for topic_partition in member_assignment_partitions:
661661
partitions_by_topic[topic_partition.topic].append(topic_partition.partition)
662-
data = StickyAssignorUserDataV1(six.viewitems(partitions_by_topic), generation)
662+
data = StickyAssignorUserDataV1(list(partitions_by_topic.items()), generation)
663663
user_data = data.encode()
664664
return ConsumerProtocolMemberMetadata(cls.version, list(topics), user_data)
665665

0 commit comments

Comments
 (0)