diff --git a/aiokafka/cluster.py b/aiokafka/cluster.py index 02cd5a83..08b59d2d 100644 --- a/aiokafka/cluster.py +++ b/aiokafka/cluster.py @@ -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,