aiokafka
aiokafka copied to clipboard
robinhood
Fork of aio-libs/aiokafka
Bumps [pygments](https://github.com/pygments/pygments) from 2.4.2 to 2.15.0. Release notes Sourced from pygments's releases. 2.15.0 Added lexers: Carbon (#2362, #2365, #2366, #2367, #2368, #2369, #2370) Dax (#2335, #2345) MediaWiki Wikitext (#2373, #827)...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
https://github.com/robinhood/aiokafka/blob/10e4119104ee32b726ab750b3e7120a85d2c7f25/aiokafka/errors.py#L71 - this does not work in kafka-python 2.x `ConnectionError` was depricated and removed in kafka-python 2.x so right now faust is failing with this trace: ``` Traceback (most recent...
Currently, in `aiokafka.record.default_records._DefaultRecordBatchPy._maybe_uncompress` it doesn't handle any compression type that is not supported. So if, for example, a record is consumed that is compressed with zstd, you will only get...
The earlier changes merged for KIP-345 (static membership protocol) missed an important part of the client changes: clients should not send a LeaveGroupRequest message when they quit or leave the...
This is a merge of aio-libs/aiokafka into robinhood/aiokafka 1.1, made to the best of my abiliites - and that's meant as a warning, as it was a pretty complex merge...
(Not sure if this should be raised on faust repo. Since the issue and fix can be on aiokafka, raising it here. Let me know if I should move it...
robinhood-aiokafka version 1.1.3 Connecting to Kafka using SASL fails with 'RuntimeError: await wasn't used with future' in aiokafka/conn.py, AIOKafkaConnection._do_sasl_handshake(): res = await authenticator.step(auth_bytes) Fix is missing await in aiokafka/conn.py: class...
The agent crashes when the producer fails to commit transactions. I am using faust 1.8.1, aiokafka 1.0.6, python 3.7 and kafka 1.1 ```2019-10-24 13:41:10.026 [1] [ERROR] faust.transport.drivers.aiokafka [^--Consumer]: Crashed reason=KafkaError('Unexpected...
When the application is unable to fetch offsets due to the following error [ERROR] aiokafka.consumer.fetcher Failed fetch offsets from 2: [Error 6] NotLeaderForPartitionError: TopicPartition(topic='xyz`) it does not force a metadata...