forked from ask/mode
-
Notifications
You must be signed in to change notification settings - Fork 19
Open
Description
Checklist
- I have included information about relevant versions
- I have verified that the issue persists when using the
masterbranch of Mode.
Steps to reproduce
Hey there, I'm building quite intense streaming application and my logs just spammed with Timer _thread_keepalive-AIOKafkaConsumerThread woke up too late when the abs(drift) value between 0.3-0.5 what from my perspective isn't a big problem and doesn't need too much reaction.
Expected behavior
It would be great if max_drift could be configured somehow so it can be set to 1.0 when the lag is inappropriate, or produce a log only when self.drifting threshold is reached.
Actual behavior
Currently there is no option to configure either the max_drift or self.drifting thresholds.
Full traceback
[2023-09-29 15:41:39,425] [7] [INFO] Timer _thread_keepalive-AIOKafkaConsumerThread woke up too late, with a drift of +0.3595487903803587 runtime=6.0498714447021484e-06 sleeptime=1.3595487903803587Versions
- Python version: 3.11
- Mode version: 0.3.5
- Operating system: osx
Metadata
Metadata
Assignees
Labels
No labels