aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
The consumers start hanging at some point with the following error being logged: ``` [2017-11-07 18:17:47,547: ERROR] Task exception was never retrieved future: ``` What might be causing the error?...
Right now bootstrap will not force wait for broker's list to contain at least 1 entree. This was made to solve issues with pre 0.9 brokers, where that scenario was...
Seems like topic auto-creation can return INVALID_REPLICATION_FACTOR error code for metadata update. Need a test to make sure this does not break anything. Thanks to @ask for the issue in...
Currently, the API always requests the whole list of topics if no subscription is present. The whole list should only be requested in case of pattern subscription.
Hello, If we try publish message into `None` topic there are some error messages: ``` Unable to request metadata from node with id 0: ConnectionError: Connection at localhost:9092 broken Unable...
Currently we send the first message ASAP from the producer. This makes code like this less efficient: ``` for i in range(10): await producer.send(topic, msg=str(i).encode()) ``` There are 2 related...
https://trustme.readthedocs.io seems cool, probably will work better, that scripts we took from librdkafka.
See https://github.com/apache/kafka/pull/2048
When processing an entry fails auto_commit will mark message as processed including the failed one. Simple example: ```python async for msg in consumer: 1/0 ``` Does consumes one message while...
- We have some research to do before. Here's the list of metrics http://kafka.apache.org/documentation.html#monitoring (correct if wrong). Select ones of interest, some don't have any meaning in `asyncio` context (like...