examples

examples copied to clipboard

### Description _What behavior does this PR change, and why?_ ### Author Validation _Describe the validation already done, or needs to be done, by the PR submitter._ ### Reviewer Tasks...

abhilash-od

DEVX-2610: Replace ccloud-exporter container/scrape/dashboard with OpenMetrics /export scrape

4

### Description https://confluentinc.atlassian.net/browse/DEVX-2610 https://confluentinc.atlassian.net/browse/DEVX-2732 https://confluentinc.atlassian.net/browse/DEVX-2733 _What behavior does this PR change, and why?_ Replace ccloud-exporter container/scrape/dashboard with OpenMetrics `/export` scrape. This removes the need for the shim provided by the...

javabrett

**Description** When the producer is run with the SASL_SSL config I get an error that says Invalid Value called as ./producer --config ./librdkafka.config --topic test response Error: KafkaError (Client config...

krishna-prasad-s

I wrote a python producer app that was consistently getting `Local: Queue full` errors (`BufferError`) and found [this code sample](https://github.com/confluentinc/confluent-kafka-python/issues/341#issuecomment-376067215) from Magnus (author of librdkafka) helpful: ```python for i in...

chuck-confluent

### Description https://confluentinc.atlassian.net/browse/DEVX-2734 _What behavior does this PR change, and why?_ In `examples/ccloud-observability`, once the cloud-stack/cluster has been created, Docker containers are launched for a producer and consumer, to create...

javabrett

Cloud events json schema

2

### Description This pull request adds an example for writing data respecting the Cloud Events Standard to Confluent Cloud, and registering the corresponding schema with Confluent Schema Registry. It is...

1123

I would like to contribute a class that shows how a user can seek to a partition and offset and retrieve a message.

vinayroyt

ERROR: Could not validate credentials to Confluent Cloud Schema Registry. Please troubleshoot

11

Hi, I'm getting the above error when trying to run the spring boot example. I believe I have the Schema Registry set up and I've generated a schema registry key....

NeilBumford

Updated Makefile-impl to use cos_containerd image

1

### Description _What behavior does this PR change, and why?_ uses the cos_containerd gke node image. Starting with version 1.24 on, dockershim is deprecated ### Author Validation https://cloud.google.com/kubernetes-engine/docs/deprecations/docker-containerd _Describe the...

jasonsmithio

kafka connectors to marketplaces

3

hey guys! I'm working with financial data streams. are there any existing fully-managed kafka connectors to marketplaces that would minimize custom WebSocket work?

sofiasedlova