confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
When I followed the [consumer-config document](https://docs.confluent.io/platform/current/installation/configuration/consumer-configs.html#fetch-max-wait-ms) and initial Consumer with additional config, following error occurred: `No such configuration property: "fetch.max.wait.ms"`  > [!NOTE] > Rewrite to `fetch.wait.max.ms` and the error...
Seeing issue with attrs dependency when installing version `2.10.0`. **Error** ```bash from confluent_kafka.schema_registry import RegisteredSchema /usr/local/lib/python3.9/site-packages/confluent_kafka/schema_registry/__init__.py:20: in from .schema_registry_client import ( /usr/local/lib/python3.9/site-packages/confluent_kafka/schema_registry/schema_registry_client.py:27: in from attrs import define as _attrs_define E...
with same API as the sync ones What ---- Checklist ------------------ - [ ] Contains customer facing changes? Including API/behavior changes - [ ] Did you add sufficient unit test...
I need to create a Kafka producer using the `confluent_kafka.Producer` that works with AWS MSK using IAM role-based authentication. To achieve this, I have developed a working solution as outlined...
For any questions/concerns about this PR, please review the [Renovate Bot wiki/FAQs](https://app.glean.com/go/renovatebot-faqs), or the [#renovatebot](https://app.glean.com/go/renovatebot-slack) Slack channel. This PR contains the following updates: | Package | Change | Age |...
![renovatebot-confluentinc[bot] avatar](https://avatars.githubusercontent.com/u/9439498?v=4 "renovatebot-confluentinc[bot] avatar"){kind=avatar}
Modified test for changes in DescribeConsumerGroups api
**Problem**: Accessing a non-existing consumer group offsets causes a segmentation fault. **Steps to Reproduce**: ```python group = ConsumerGroupTopicPartitions(group_id = "non-existing-group") kafkaAdmin.list_consumer_group_offsets([group])["not-existing-group"].result() ``` **Expected Behavior**: This should throw an exception (like...
### What is the current behavior? Unable to install the package from pip. ### What is the desired behavior? To have [native wheel for WoA](https://blogs.windows.com/windowsdeveloper/2025/04/14/github-actions-now-supports-windows-on-arm-runners-for-all-public-repos/). GitHub Actions now supports win-arm64...
Hi team 👋, While working with the confluent_kafka.admin.ConfigResource class, I noticed an inconsistency in the documentation regarding incremental config updates: Issue: • The constructor has an argument named incremental_configs, which...
The official documentation page, still mentions 2.8.0 as current version by Pypy is already on 2.10.0 https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html  Releases: https://pypi.org/project/confluent-kafka/#history
