confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== We have configured strimzi kafka with 9092 as non secured port and with 9093 as secured port. While trying to produce the messages by connecting to 9092 (non...
This change allows schema registry clients to specify a token in case the registry server supports token/oidc authentication.
Description =========== I'm working on using confluent kafka python client to consume using ssl. I have no issue with setting the path of cert to ssl.ca.location. However, if I tried...
OverflowError: Python int too large to convert to C int when using confluent_kafka Avro deserializer
Description =========== I'm encountering an OverflowError when attempting to deserialize messages using the **confluent_kafka **Avro deserializer in Python. Here's a simplified version of my code: ``` class ConsumerKafka: def __init__(self,...
Description =========== The `Producer` and `Consumer` can use Python logging via the `logger` configuration option. This works well as long as the program is running. Unfortunately, the last log messages...
Description =========== Attempting to hard-delete a subject that has been soft-deleted ends up throwing a 404 error and will never execute the hard-delete API call. How to reproduce ================ 1....
Description =========== I am simply trying to create a topic in Kafka and roughly half the time I'm running into this error. Here's an MVCE: ``` from confluent_kafka.admin import NewTopic,...
Description =========== Kafka returning same set of records even after full records fetched from the table * Iam using connector api for producer and consumer code in separate file to...
Description =========== String representation of a TopicPartition raises a SystemError on Windows with Python 3.12.1 and Confluent Kafka Python 2.3.0. How to reproduce ================ ```Python (test-2024-02-28) PS C:\gdavey\src\test> python Python...
Description =========== How to reproduce ================ ## Set up some variables to use ``` >>> from datetime import datetime >>> from confluent_kafka import TopicPartition >>> >>> topic = 'topic_name' #...
