From 83b7b2752fecdfef00bb03e7c2a3ac1fe8c2d0d3 Mon Sep 17 00:00:00 2001 From: Valeria Chernenko Date: Sat, 31 Oct 2020 06:31:45 +0100 Subject: [PATCH] Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154) --- kafka/coordinator/assignors/sticky/sticky_assignor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/coordinator/assignors/sticky/sticky_assignor.py b/kafka/coordinator/assignors/sticky/sticky_assignor.py index 782708686..eb83c010b 100644 --- a/kafka/coordinator/assignors/sticky/sticky_assignor.py +++ b/kafka/coordinator/assignors/sticky/sticky_assignor.py @@ -656,7 +656,7 @@ def metadata(cls, topics): 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)