aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
I have a cluster of a few hundred consumers in a single consumer group, and I want to get the mapping between the node hostnames and the member UUID in...
### Changes Fixes #685 `__aenter__` is supposed to return the object that populates the `instance` variable in `async with Constructor(params) as instance:` ### Checklist - [x] I think the code...
Hey, I ran into the following bug (or unexpected behavior) and would be glad to get your help with that, or any idea to what I'm doing wrong. This bug...
Kafka-python added it with 1.1.1. After migrating we should add it too. Update tests and docs
Hi, python-kafka simply works with oauthbearer. With aiokafka there are zero examples I am flying blind. Did I impelent CustomTokenProvider correct? the create_ssl_context() function is what i use in python-kafka...
We use `kafka-python` and have a problem that maybe `aiokafka` could solve. We have a system that consumes messages one-at-a-time and can take a long time to process (up to...
Port `murmur2` from `python-kafka` and rewrite in `cython` for better performance.
## What do these changes do? Add new callbacks for connection opened/close for consumer and producer ## Are there changes in behavior for the user? User may add callbacks if...
**Describe the bug** ```python async with AIOKafkaProducer(...) as producer: producer.send(...) ``` fails with `AttributeError: 'NoneType' object has no attribute 'send'`. `producer` is indeed `None`. **Expected behaviour** `producer` is an `AIOKafkaProducer`...
**Describe the solution you'd like** Implement support for static group membership to avoid unnecessary rebalances [KIP-345](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances) **Additional context** Implemented in the java kafka library to redduce unnecessary rebalances
