diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-10 22:47:13 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-10 23:00:09 -0800 |
| commit | 0adb71af3858a8f4d1cfb3fe072989499b3b3c4f (patch) | |
| tree | d254f668fe4b1e064bb021aff097d406e7f9b949 /kafka/consumer/group.py | |
| parent | 829b0379eb6f4df2e20fceb6673ad60e21b348f3 (diff) | |
| download | kafka-python-0adb71af3858a8f4d1cfb3fe072989499b3b3c4f.tar.gz | |
Fetcher logging should be debug or trace (left higher during testing)
Diffstat (limited to 'kafka/consumer/group.py')
| -rw-r--r-- | kafka/consumer/group.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 704c994..d83c452 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -639,6 +639,7 @@ class KafkaConsumer(six.Iterator): for msg in self._fetcher: yield msg if time.time() > timeout_at: + log.debug("internal iterator timeout - breaking for poll") break def __iter__(self): # pylint: disable=non-iterator-returned |