Closing connection

[Abraham-liuhai]

Steps to reproduce

app = App(topic_name, broker) app.conf.consumer_auto_offset_reset = "latest" # earliest latest app.conf.broker_heartbeat_interval = 60 topic = app.topic(topic_name) Appears approximately one day after starting Faust Timer Recovery.stats woke up too late and Closing connection And then Faus seems to have been dead and won't consume any more news

# Versions

* Python version 3.9
* Faust version faust-streaming==0.10.21
* Operating system
* Kafka version
* RocksDB version (if applicable)