aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
### Changes Fixes https://github.com/aio-libs/aiokafka/issues/842 * Now it is possible to set the `ConsumerRebalanceListener` when a `Consumer` instance is created. * The validation is made in the `SubscriptionState._validate_rebalance_listener` method. * The...
Hi, do you know when there may be a new release? I'm interested in zstd compression support which was added in https://github.com/aio-libs/aiokafka/pull/801
**Describe the bug** If a Consumer has no partitions assigned, it will eventually timeout and leave the consumer group, which means that it will not be available for assignment on...
### Description We have long running service, which processes messages through the aiokafka, running in coroutine. Once in a few days `Failed fetch messages from 1: [Error 7] RequestTimedOutError` happens...
The documentation for [`AIOKafkConsumer` on `readthedocs.io`](https://aiokafka.readthedocs.io/en/stable/api.html#aiokafka.AIOKafkaConsumer) does not have documentation for the `getone` and `getmany` methods. The source code for those methods has docstrings, so I'm expecting the generated docs...
**Describe the bug** When consuming messages from a broker where compression has been set at the broker level with ZSTD compression, the Consumer fails with an UnknownError. This does not...
Hi, I found out that the SCRAM SASL mechanism is likely forgotten in the logging logic at conn.py. I am using a SCARAM-SHA-256 SASL mechanism and after a client successfully...
Hey can we catch "NodeNotReadyError" exception while consuming from Kafka . So that we can take any action at this situation. Like sending alert.
**Describe the bug** I'm getting some irrelevant warning logs after the first few initial connection attempts fail during the boot of Kafka. I start all the containers with a docker-compose...
Hi all, According to the docs `AIOKafkaConsumer` can be created with multiple topics - however only _one_ deserializer can be passed for value/key. Assuming we have topics with _different_ message...
