aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
Dear Taras and Denis, thank you so much for all of your answers within #665 and for picking up the work on `aiokafka`. I would like to share a story...
**Describe the bug** I'm noticing that heartbeats are not being sent from a background thread when using the "Transaction Consume-Process-Produce" paradigm described [here](https://aiokafka.readthedocs.io/en/stable/examples/transaction_example.html). **Expected behaviour** I expect the logger to...
AFAIK based on this [issue](https://github.com/robinhood/faust/issues/271) the main differences are: Consumer: Request rebalance if topics were marked as missing, instead of just hanging. Kafka has a auto-create topics that kicks in...
**Describe the solution you'd like** When using `AIOKafkaConsumer.getone()` with a list of topic partitions, it may be nice to log a warning if there is no overlap between the requested...
After #456 I think it makes sense to put some kind of protection in case all nodes are not available. I feel like using bootstrap nodes list is not a...
Implementing a test context would be more preferable since testing with a real instance is impossible with multiple test workers: I have two of ten test runs failed due to...
Aiokafka consumers and producers are writing many important logs, which saving them would be usefull. However, as far as i know there is no offical way for changing the aiokafka...
like the python-kafka client has? if yes, i could start with a small PR that would add (what i consider) the most frequently used requrests like topic create / delete...
**Describe the bug** Randomly, kafka consumer failed to fetch new messages, then kicked out of the consumer group after max_poll timeout, but failed to rejoin **Expected behaviour** The consumer should...
**Describe the solution you'd like** Add configuration to decouple request timeout from send delivery timeout. See https://kafka.apache.org/documentation/#delivery.timeout.ms. **Additional context** The issue reported https://github.com/aio-libs/aiokafka/issues/624 may be related and mitigated using this...