Skip to content

Commit 8e7ea69

Browse files
authored
Fix typo (#2096)
1 parent 91daea3 commit 8e7ea69

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/consumer/fetcher.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -293,7 +293,7 @@ def _retrieve_offsets(self, timestamps, timeout_ms=float("inf")):
293293
# Issue #1780
294294
# Recheck partition existence after after a successful metadata refresh
295295
if refresh_future.succeeded() and isinstance(future.exception, Errors.StaleMetadata):
296-
log.debug("Stale metadata was raised, and we now have an updated metadata. Rechecking partition existance")
296+
log.debug("Stale metadata was raised, and we now have an updated metadata. Rechecking partition existence")
297297
unknown_partition = future.exception.args[0] # TopicPartition from StaleMetadata
298298
if self._client.cluster.leader_for_partition(unknown_partition) is None:
299299
log.debug("Removed partition %s from offsets retrieval" % (unknown_partition, ))

0 commit comments

Comments
 (0)