We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 6f932ba + 83b7b27 commit ca57fe2Copy full SHA for ca57fe2
kafka/coordinator/assignors/sticky/sticky_assignor.py
@@ -656,7 +656,7 @@ def metadata(cls, topics):
656
partitions_by_topic = defaultdict(list)
657
for topic_partition in cls.member_assignment: # pylint: disable=not-an-iterable
658
partitions_by_topic[topic_partition.topic].append(topic_partition.partition)
659
- data = StickyAssignorUserDataV1(six.iteritems(partitions_by_topic), cls.generation)
+ data = StickyAssignorUserDataV1(six.viewitems(partitions_by_topic), cls.generation)
660
user_data = data.encode()
661
return ConsumerProtocolMemberMetadata(cls.version, list(topics), user_data)
662
0 commit comments