Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closing connection #603

Open
Abraham-liuhai opened this issue Jan 29, 2024 · 0 comments
Open

Closing connection #603

Abraham-liuhai opened this issue Jan 29, 2024 · 0 comments

Comments

@Abraham-liuhai
Copy link

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

image


# Versions

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant