-
Notifications
You must be signed in to change notification settings - Fork 180
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
Error when creating a topic using aiokafka 0.11.0 #630
Comments
Do you need the Faust application to create the topic? Can you try to add the topic manually with the Kafka topic scripts and see if that helps? |
Usually I don't need faust to create a topic, usually faust just creates the leader topic for me. I know there are other ways to create topics, it's just a matter of me finding out about it and letting it be known! |
I have an issue with my applications where if I use Faust to create the topics it often results in a topic not being created (something about topic can't be used while being created) and then the error message ignoring missing topic: . I think this is due to a large volume of applications being started at the same time and the CPU is wildly overloaded. To get around this, I manually create the topics before hand using the kafka_topics.sh (or .bat if using windows) that's part of your kafka download and found in the bin directory. For me, when ever I start my application I first run: The --if-not-exists argument will only create the topic if it doesn't already exist. |
I'm seeing the same issue with the combination of faust 0.11.0 and aiokafka 0.10.0. Forcing aiokafka==0.10.0 fixes the issue. |
Added a PR for this #631, can someone have a look? |
poetry add faust-stream
error
AttributeError: 'CreateTopicsRequest_v1' object has no attribute 'build_request_header'
No problems with aiokafka 0.10.0
The text was updated successfully, but these errors were encountered: