Fix typo (dpkp#2096)

aiven · Sep 22, 2020 · 1a3b19d · 1a3b19d
1 parent 3b45477
commit 1a3b19d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
@@ -293,7 +293,7 @@ def _retrieve_offsets(self, timestamps, timeout_ms=float("inf")):
                 # Issue #1780
                 # Recheck partition existence after after a successful metadata refresh
                 if refresh_future.succeeded() and isinstance(future.exception, Errors.StaleMetadata):
-                    log.debug("Stale metadata was raised, and we now have an updated metadata. Rechecking partition existance")
+                    log.debug("Stale metadata was raised, and we now have an updated metadata. Rechecking partition existence")
                     unknown_partition = future.exception.args[0]  # TopicPartition from StaleMetadata
                     if self._client.cluster.leader_for_partition(unknown_partition) is None:
                         log.debug("Removed partition %s from offsets retrieval" % (unknown_partition, ))