confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== After enabling collecting stats (using `stats_cb`) I've noticed, that some of our services started consuming much more memory. I was not able to trace it back exactly to...
Description =========== Is there any way to setup authentication with Schema Registry using SchemaRegistryClient with Oauth instead of basic username password? This is enabled for the Java client See -...
Hi, Sorry, this is the only medium I could use to correct this. In the course "Kafka for Python developers", the [video](https://developer.confluent.io/courses/kafka-python/adminclient-class/), at time 2 mins: 37 secs. You listed...
Custom partitioner has been removed for a long time in favor of using the predefined set of partitioners from librdkafka (https://github.com/confluentinc/confluent-kafka-python/pull/396) but 'known bug' note still exists. This note is...
Description =========== We have spotted the following behavior after moving to version 2.5.0. After regular AWS MSK maintenance where all brokers are restarted one by one, we can see in...
Other confluent-kafka-python APIs accept seconds since epoch, but this one uses milliseconds, so it's easy to think it accepts seconds. That would generally result in replaying all events.
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}
Adds contributor markdown and cleans up some of documentation. This is an effort as a precursor to engaging the community for completely. ---- This adds a Contributor.md file, changes the...
Description =========== We have a producer that produces to a topic and does not have Write permissions on it. If I would produce to it, I would expect the produce...
### Description While reading through the codebase, I came across a comment in [src/confluent_kafka/src/Producer.c](https://github.com/confluentinc/confluent-kafka-python/blob/v2.10.0/src/confluent_kafka/src/Producer.c) that states: ```c /** * @brief KNOWN ISSUES * * - Partitioners will cause a dead-lock...
