summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNikolay Vasiliev <lonlylocly@yandex.ru>2021-02-20 23:18:49 +0100
committerGitHub <noreply@github.com>2021-02-20 14:18:49 -0800
commit6521c1d5ee9cdc2e9d7ee373015ccd639525d350 (patch)
tree6abe74890ca61f30eb8ac0829c12149ee7b75aef
parent9feeb79140ed10e3a7f2036491fc07573740c231 (diff)
downloadkafka-python-6521c1d5ee9cdc2e9d7ee373015ccd639525d350.tar.gz
fix typo in documentation (#2178)
-rw-r--r--kafka/admin/client.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/admin/client.py b/kafka/admin/client.py
index 63a0f3b..fd4d661 100644
--- a/kafka/admin/client.py
+++ b/kafka/admin/client.py
@@ -1209,7 +1209,7 @@ class KafkaAdminClient(object):
: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 @@ class KafkaAdminClient(object):
.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: