File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1209,7 +1209,7 @@ def _list_consumer_group_offsets_process_response(self, response):
1209
1209
1210
1210
:param response: an OffsetFetchResponse.
1211
1211
:return: A dictionary composed of TopicPartition keys and
1212
- OffsetAndMetada values.
1212
+ OffsetAndMetadata values.
1213
1213
"""
1214
1214
if response .API_VERSION <= 3 :
1215
1215
@@ -1223,7 +1223,7 @@ def _list_consumer_group_offsets_process_response(self, response):
1223
1223
.format (response ))
1224
1224
1225
1225
# transform response into a dictionary with TopicPartition keys and
1226
- # OffsetAndMetada values--this is what the Java AdminClient returns
1226
+ # OffsetAndMetadata values--this is what the Java AdminClient returns
1227
1227
offsets = {}
1228
1228
for topic , partitions in response .topics :
1229
1229
for partition , offset , metadata , error_code in partitions :
You can’t perform that action at this time.
0 commit comments