confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== deleteRecords equiv from Java does not seem to be exposed in AdminClient, on checking librdkafka it exists in the underlying C++ lib, just not exposed up in python...
Adding `timeout` kw-only parameter to all schema registry client methods. Fixes #905
an additional byte must be added for the closing zeros
Description =========== In golang implementation OffsetTail is available which returns the logical offset relativeOffset from current end of partition. It would be great to have this also available in python....
Fixes https://github.com/confluentinc/confluent-kafka-python/issues/1408 This PR does at least an initial pass of adding typing support. Please note it does not support Python 2 at the moment ([although that might be getting...
Description =========== I'm facing a problem since I deployed redpanda inside a kubernetes cluster (following those instructions: https://docs.redpanda.com/current/deploy/deployment-option/self-hosted/kubernetes/kubernetes-deploy/?tab=tabs-1-helm#tabs-1-helm) : ~~~ redpanda.lysredge.svc.cluster.local:9093/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect...
Data files are installed in the wrong directory when packaging this, and it is very uncommon to do so. data files should be files needed for the runtime only.
Description =========== On centos 7, getting error when importing confluent kafka 2.2.0 in python script. The confluent-kafka module was built using the source along with librdkafka. Getting below error when...
Update mac agent to 13.5 which is close to developer's local versions. new mac agent syntax is same as ubuntu agents
Hello! My usecase is consuming a certain timeframe from a single topic with multiple consumers in a meaningful manner in case of fault (cooperative sticky assignor). But for now I...
