Skip to content

Commit

Permalink
Explain the unpacking catch all
Browse files Browse the repository at this point in the history
  • Loading branch information
Vincent Maurin committed Jan 29, 2024
1 parent a4aad3a commit 927472e
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions aiokafka/cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -254,6 +254,7 @@ def update_metadata(self, metadata):
error_type = Errors.for_code(error_code)
if error_type is Errors.NoError:
_new_partitions[topic] = {}
# Starting with v5, MetadataResponse contains more than 5 fields
for p_error, partition, leader, replicas, isr, *_ in partitions:
_new_partitions[topic][partition] = PartitionMetadata(
topic=topic,
Expand Down

0 comments on commit 927472e

Please sign in to comment.