diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2018-05-10 16:29:30 -0700 |
---|---|---|
committer | Jeff Widman <jeff@jeffwidman.com> | 2018-05-10 16:33:37 -0700 |
commit | 9221fcf83528b5c3657e43636cb84c1d18025acd (patch) | |
tree | 43104d8c29ce7d9d0c64250278df89158e919b40 | |
parent | 27f939ad528a5f7f71346c3d9b18e1a9aa9404e5 (diff) | |
download | kafka-python-9221fcf83528b5c3657e43636cb84c1d18025acd.tar.gz |
Stop using deprecated log.warn()
-rw-r--r-- | kafka/consumer/fetcher.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index ea7d5d8..6ec1b71 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -610,7 +610,7 @@ class Fetcher(six.Iterator): future.failure(error_type(partition)) return elif error_type is Errors.UnknownTopicOrPartitionError: - log.warn("Received unknown topic or partition error in ListOffset " + log.warning("Received unknown topic or partition error in ListOffset " "request for partition %s. The topic/partition " + "may not exist or the user may not have Describe access " "to it.", partition) @@ -821,10 +821,10 @@ class Fetcher(six.Iterator): raise Errors.OffsetOutOfRangeError({tp: fetch_offset}) elif error_type is Errors.TopicAuthorizationFailedError: - log.warn("Not authorized to read from topic %s.", tp.topic) + log.warning("Not authorized to read from topic %s.", tp.topic) raise Errors.TopicAuthorizationFailedError(set(tp.topic)) elif error_type is Errors.UnknownError: - log.warn("Unknown error fetching data for topic-partition %s", tp) + log.warning("Unknown error fetching data for topic-partition %s", tp) else: raise error_type('Unexpected error while fetching data') |