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...