aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
Hi, when I run aiokafka consumer with consumer_timeout=100, it should terminate 100ms after reaching the end of the topic; instead (as demonstrated in the attached notebook) it hangs on, presumably...
Currently Consumer does something like: ``` assert all(map(lambda k: isinstance(k, TopicPartition), partitions)) ``` * Replace this with a proper value check, raise sensible errors like TypeError or ValueError. * Add...
The error message is not clear. See conversation [here](https://stackoverflow.com/a/40200328/1252307). It is also not clear if that is even an error or not. It would be helpful if the error message...
### Changes `AIOKafkaConsumer.highwater` is not an async method: https://github.com/aio-libs/aiokafka/blob/6360747c4305d1d096d5e55037d60a12c4c9ab15/aiokafka/consumer/consumer.py#L668 Remove an `await` before a call to `consumer.highwater` in an example in the docs.
### Changes Remove leftover Travis CI references, which currently lead to error pages. ### Checklist - [X] I think the code is well written - [X] Unit tests for the...
**Describe the solution you'd like** Currently `consumer.committed()` returns offset number. However Kafka stores optional metadata with committed offsets with metadata in struct `OffsetAndMetadata`, and the method `committed()` simply returns only...
**Describe the solution you'd like** The ability to set `ssl_check_hostname` in addition to the `ssl_context`. **Additional context** [kafka-python's KafkaConsumer](https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html#kafka.KafkaConsumer) supports this parameter to be able to disable whether the SSL/TLS...
**Describe the solution you'd like** I'd like to propose adding type hints to the `Aiokafka` project. I've used `mypy` to analyze the codebase, and I believe that adding type hints...
### Changes add more typo for integrate with mypy Fixes #980 ### Checklist - [x] I think the code is well written - [x] Unit tests for the changes exist...