aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
### Changes This adds an example of concurrent consumption to the docs. While the idea is simple, in my experience developers/teams don't always arrive to it straightforwardly, and would benefit...
I have tried the [transaction_example example](https://aiokafka.readthedocs.io/en/stable/examples/transaction_example.html) provided in the documentation and it does not work. After checking the code, I see that the it get stuck when starting the producer...
### Changes This adds a round robin partitioner. When message ordering is not a concern, this can increase consumption throughput by ensuring a more unform temporal spacing between messages in...
**Describe the solution you'd like** Currently, `AIOKafkaConsumer.end_offsets` fires off either an `OffsetRequest_v0` or `OffsetRequest_v1` message to the broker. Here, the broker will reply with the high watermark (HWM), but if...
I wonder what's wrong with explicitly passing the desired loop to Producer and Consumer? https://github.com/aio-libs/aiokafka/blob/master/aiokafka/consumer/consumer.py#L273 https://github.com/aio-libs/aiokafka/blob/master/aiokafka/producer/producer.py#L231
Hi team, I’m trying to understand how partition reassignment works in `aiokafka` and ran into some confusion regarding the behavior described in the documentation for `ConsumerRebalanceListener`. Specifically, the documentation suggests...
I have http API service on fastapi that only write to kafka by aiokafka. So I only one producer cause very high fetch rate on monitoring graphs - usually 3.5-4k...
Hello, we face issues to detect the connection status to the broker with a consumer. We have the requirement to generate a notification, if the connection to the broker is...
