confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== I'm seeing an unexpected approx. 1 second delay in producing the first message (despite specifying queue.buffering.max.ms=0) How to reproduce ================ Run the following code: ``` import base64 import...
This PR builds on #1126 (retains commit history). Since there are comments on the prior PR, I'll both add those comments here and address them here.
This is a routine update from cc-service-bot based on the service.yml in your repo. This PR should be approved and merged as soon as CI passes.
Description =========== Admin client cannot connect to the bootstrap servers when using `SASL_SSL` with `OAUTHBEARER`. I'm trying to connect to AWS MSK cluster bootstrap servers. Admin client can connect when...
Description =========== In the [`Message.__len__` method](https://github.com/confluentinc/confluent-kafka-python/blob/23b4142a3b1f779ca31b6d082c37a51e622346e3/src/confluent_kafka/src/confluent_kafka.c#L697) it gets the length of the value and returns that. Unfortunately, this means that if a user is using a `DeserializingConsumer` that deserializes the...
Description =========== I'm using Celery to parallelize a process of ingesting data to a Kafka topic. What I've noticed is that some messages do not end up in Kafka even...
Description =========== The issue is seen when a node is brought down in a 3-node cluster wherein one of the topic partitions had an ISR count of 1 against a...
Description =========== The package in PyPI has two main issues: - no README or description - misses to declare own dependencies (e.g. `requests` or `fastavro`) How to reproduce ================ -...
Description =========== I was working on code to produce messages to a Kafka topic. The messages are protobuf bytes and I used SerializingProducer to pass the schema information. I tried...
Adapt `AdminClient` constructor to match `Consumer` and `Producer` ones that allow to specify the logger to use.
