From b52c58ddb86d0b7ec53b2ab3277fed879c81b646 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Thu, 11 Jan 2018 14:21:47 -0800
Subject: Log __del__ cleanups

---
 kafka/consumer/fetcher.py | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'kafka/consumer/fetcher.py')

diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
index 6ec1b71..01deb5c 100644
--- a/kafka/consumer/fetcher.py
+++ b/kafka/consumer/fetcher.py
@@ -120,6 +120,9 @@ class Fetcher(six.Iterator):
         self._sensors = FetchManagerMetrics(metrics, self.config['metric_group_prefix'])
         self._isolation_level = READ_UNCOMMITTED
 
+    def __del__(self):
+        log.debug('%s: __del__', self)
+
     def send_fetches(self):
         """Send FetchRequests for all assigned partitions that do not already have
         an in-flight fetch or pending fetch data.
-- 
cgit v1.2.1