From 7a6f2349ea05bda9ee6103e7f8214b9778ebcce6 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Sun, 10 Jul 2016 23:59:05 -0700
Subject: Add comment re fetcher stats on compressed topics

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

(limited to 'kafka')

diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
index 9b36354..d615848 100644
--- a/kafka/consumer/fetcher.py
+++ b/kafka/consumer/fetcher.py
@@ -729,6 +729,8 @@ class Fetcher(six.Iterator):
                 else:
                     raise error_type('Unexpected error while fetching data')
 
+        # Because we are currently decompressing messages lazily, the sensors here
+        # will get compressed bytes / message set stats when compression is enabled
         self._sensors.bytes_fetched.record(total_bytes)
         self._sensors.records_fetched.record(total_count)
         if response.API_VERSION >= 1:
-- 
cgit v1.2.1