diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 63a0f3bb7..fd4d66110 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -1209,7 +1209,7 @@ def _list_consumer_group_offsets_process_response(self, response): :param response: an OffsetFetchResponse. :return: A dictionary composed of TopicPartition keys and - OffsetAndMetada values. + OffsetAndMetadata values. """ if response.API_VERSION <= 3: @@ -1223,7 +1223,7 @@ def _list_consumer_group_offsets_process_response(self, response): .format(response)) # transform response into a dictionary with TopicPartition keys and - # OffsetAndMetada values--this is what the Java AdminClient returns + # OffsetAndMetadata values--this is what the Java AdminClient returns offsets = {} for topic, partitions in response.topics: for partition, offset, metadata, error_code in partitions: