diff options
| author | KimDongMin <dkrahd12@gmail.com> | 2020-09-08 07:08:51 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-07 15:08:51 -0700 |
| commit | 8e7ea69e6b6866a339023454dfaa075721b33dbf (patch) | |
| tree | ebfb4ac1e85622ee05d09852d2c515690537da2b | |
| parent | 91daea329bb40ed80bddef4635770d24b670b0c6 (diff) | |
| download | kafka-python-8e7ea69e6b6866a339023454dfaa075721b33dbf.tar.gz | |
Fix typo (#2096)
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 2c11eb9..e4f8c18 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -293,7 +293,7 @@ class Fetcher(six.Iterator): # 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, )) |