confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
What ---- Typehint the serialization module. Makes the library more user friendly.
What ---- Adds OTEL config which would be used by OTEL agent to export the metrics and logs of Soak tests to Datadog. Instructions to install OTEL agent on EC2:...
### Discussed in https://github.com/confluentinc/confluent-kafka-python/discussions/1583 Originally posted by **pchatterjee-cfx** June 12, 2023 Hi, I am looking for a way to create an owner for a topic and subseqeuently add ACL rules...
Factors out the parsing logic from DeserializingConsumer.poll() to reuse in consume().
What ---- Checklist ------------------ - [ ] Contains customer facing changes? Including API/behavior changes - [ ] Did you add sufficient unit test and/or integration test coverage for this PR?...
Description =========== Using the AdminClient describeTopic feature returned a corrupted topic.id on windows x86 environement. How to reproduce ================ Just describe a topic using admin_client.describe_topics(TopicCollection(topic_names=['topic-name'])) and compare in the result...
Description =========== We have a setup where we want to query all acls using admin client and then filter them. While using **AdminClient().describe_acls(acl_filter) we are getting segmentation fault.** Note that...
# Description I used confluent-kafka-python to write a worker responsible for processing messages in a specific kafka topic. To implement EOS (Exactly Once Semantics), I enabled transactions and configured the...
Description =========== Seems that the Python client with the latest update to 2.6.2 is broken... All kinds of modules probably required for httpx are seemingly not listed in the dependencies...
Hi, there are still two more issues wrt SR API coverage when it comes to soft/hard delete. 1) get_subjects() Does not support the boolean "deleted" parameter. In the SR API,...