aiokafka
aiokafka copied to clipboard
aio-libs
asyncio client for kafka
**Describe the bug** `test_read_write_serde_v2` fails because CRC do not match. See: https://koji.fedoraproject.org/koji/taskinfo?taskID=124232877 -> `build.log` or paste below: ``` if crc is not None: > assert reader.crc == crc E assert...
**Describe the bug** I have a long running fastapi app which will start a consumer on app start and consume messages from kafka. The consumer works fine for maybe a...
Bumps [actions/download-artifact](https://github.com/actions/download-artifact) from 2 to 4.1.7. Release notes Sourced from actions/download-artifact's releases. v4.1.7 What's Changed Update @actions/artifact dependency by @bethanyj28 in actions/download-artifact#325 Full Changelog: https://github.com/actions/download-artifact/compare/v4.1.6...v4.1.7 v4.1.6 What's Changed updating @actions/artifact...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
### Changes Fixes #1038 ### Checklist - [ ] I think the code is well written - [x] Unit tests for the changes exist - [ ] Documentation reflects the...
**Describe the solution you'd like** A new function in the admin client that lets me retrieve the offsets (earliest/latest) of each partition. **Additional context** Confluent's admin client has [list_offsets](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/_modules/confluent_kafka/admin.html#AdminClient.list_offsets). My...
I'm doing kind of health-check stuff for consumers and would like to leverage current heartbeat state to do it. Like mark the consumer pod as failed once the heartbeat is...
aiokafka [relies on `ioloop.create_task()`](https://github.com/aio-libs/aiokafka/blob/v0.11.0/aiokafka/producer/sender.py#L76) method, which run coroutine in background and makes it "cancelable". The problem that [the tasks list in asyncio is public](https://docs.python.org/3/library/asyncio-task.html#asyncio.all_tasks) and external code can cancel `sender_task`....
**Describe the bug** We are using aiokafka and uvloop. When connection closed from server and aiokafka do attempt to send something to it, RuntimeError is raised (but only OSError is...
**Describe the bug** In #960, when switching compression libraries, the default compression settings for LZ4 were also changed. In `python-lz4`, the default level was 0. Now it is 9. We...
feat: add FetchRequest v10 support (Kafka ≥ 2.6, KIP-110/320) > **Problem** > `aiokafka` always sends **FetchRequest v4**. > When a topic or broker is configured with **`compression.type=zstd`** (default since Kafka...
