diff options
| -rw-r--r-- | kafka/coordinator/assignors/sticky/sticky_assignor.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/assignors/sticky/sticky_assignor.py b/kafka/coordinator/assignors/sticky/sticky_assignor.py index 7827086..eb83c01 100644 --- a/kafka/coordinator/assignors/sticky/sticky_assignor.py +++ b/kafka/coordinator/assignors/sticky/sticky_assignor.py @@ -656,7 +656,7 @@ class StickyPartitionAssignor(AbstractPartitionAssignor): partitions_by_topic = defaultdict(list) for topic_partition in cls.member_assignment: # pylint: disable=not-an-iterable partitions_by_topic[topic_partition.topic].append(topic_partition.partition) - data = StickyAssignorUserDataV1(six.iteritems(partitions_by_topic), cls.generation) + data = StickyAssignorUserDataV1(six.viewitems(partitions_by_topic), cls.generation) user_data = data.encode() return ConsumerProtocolMemberMetadata(cls.version, list(topics), user_data) |