diff options
| author | Valeria Chernenko <aynroot@users.noreply.github.com> | 2020-10-31 06:31:45 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-10-30 22:31:45 -0700 |
| commit | 83b7b2752fecdfef00bb03e7c2a3ac1fe8c2d0d3 (patch) | |
| tree | 703d47824af1db25346309023dc1511dc377125b | |
| parent | 6f932ba71c150b6c03bf509829c35baa30f564b8 (diff) | |
| download | kafka-python-83b7b2752fecdfef00bb03e7c2a3ac1fe8c2d0d3.tar.gz | |
Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154)
| -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) |