We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
As there is self._closed = False in __init__, then it requires to call await producer.stop() even if it is not started.
self._closed = False
__init__
await producer.stop()
producer = aiokafka.AIOKafkaProducer(bootstrap_servers="localhost:9092") del producer # Unclosed AIOKafkaProducer
aiokafka/aiokafka/producer/producer.py
Lines 286 to 294 in 00349a8
The text was updated successfully, but these errors were encountered:
No branches or pull requests
As there is
self._closed = False
in__init__
, then it requires to callawait producer.stop()
even if it is not started.aiokafka/aiokafka/producer/producer.py
Lines 286 to 294 in 00349a8
The text was updated successfully, but these errors were encountered: