From 563e38a84f75d2ce3df23f1734d08feaaefe24b6 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 29 Dec 2015 17:36:11 -0800 Subject: [PATCH] Dont warn in AutoCommitTask.disable if not previously scheduled --- kafka/coordinator/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 67b4b6d..92a840d 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -540,7 +540,7 @@ class AutoCommitTask(object): try: self._client.unschedule(self) except KeyError: - log.warning("AutoCommitTask was not previously scheduled") + pass def _reschedule(self, at): if self._enabled: