aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
**Describe the bug** Here what I posted on the kafka user mailing list > I am working on an exactly once stream processors in Python, using > aiokafka client library....
**Describe the bug** to the best of my knowledge, the consumer is _**somehow**_ dropping a connection to the kakfa brokers, and when it tries to reconnect it also seems to...
Hello First of all, thanks for this nice project! I am using `aiokafka` and it has been doing great job for a couple of months in my project. Recently I...
I am wondering if there are any noticeable bugs in this code? I am running into some issues with my code and wondering if anything jumps out. 1. every time...
As there is `self._closed = False` in `__init__`, then it requires to call `await producer.stop()` even if it is not started. ```python producer = aiokafka.AIOKafkaProducer(bootstrap_servers="localhost:9092") del producer # Unclosed AIOKafkaProducer...
**Describe the bug** I got this error when trying to produce the message using aiokafka 0.8.1 and Python 3.11.6 This urls might useful for someone who is smarter than me...
### Changes Adds typings for `helpers` and `errors` modules ### Checklist - [x] I think the code is well written - [ ] Unit tests for the changes exist -...
**Describe the bug** I have a code (added below). It first fetches a message and sends it to a new topic using the producer transaction and sends the offsets using...
**Describe the bug** After some number of producer.send_and_wait(topic,message) (it could be 15k successfully sended messages), I've got: ``` ERROR Unexpected error in sender routine sender.py:167 ╭───────────────────────────────────────────────────────────────────── Traceback (most recent call...
Hi 👋🏻 I have a pytest test with parametrization (7 tests), that produce and consume simple msg with simple logic. It uses kafka cluster with 3 nodes, each test creates...
