Skip to content

Commit

Permalink
fix typo in documentation (#2178)
Browse files Browse the repository at this point in the history
  • Loading branch information
lonlylocly authored Feb 20, 2021
1 parent 9feeb79 commit 6521c1d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions kafka/admin/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:

Expand All @@ -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:
Expand Down

0 comments on commit 6521c1d

Please sign in to comment.