diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-10 23:59:05 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-16 14:05:50 -0700 |
| commit | 7a6f2349ea05bda9ee6103e7f8214b9778ebcce6 (patch) | |
| tree | 4e67706aa22d8b824aa2b29282dc47001453cd21 | |
| parent | abaea8e4b9110c54bf4b2b14a4cdd007b1ce7e29 (diff) | |
| download | kafka-python-7a6f2349ea05bda9ee6103e7f8214b9778ebcce6.tar.gz | |
Add comment re fetcher stats on compressed topics
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 |
1 files changed, 2 insertions, 0 deletions
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: |