SkillAgentSearch skills...

Examples

Apache Kafka, Apache Flink and Confluent Platform examples and demos

Install / Use

/learn @confluentinc/Examples

README

image

Overview

This is a curated list of demos that showcase Apache Kafka® event stream processing on the Confluent Platform, an event stream processing platform that enables you to process, organize, and manage massive amounts of streaming data across cloud, on-prem, and serverless deployments.

<p align="center"> <a href="http://www.youtube.com/watch?v=muQBd6gry0U" target="_blank"><img src="images/examples-video-thumbnail.jpg" width="360" height="270" border="10" /></a> </p>

Where to start

The best demo to start with is cp-demo which spins up a Kafka event streaming application using ksqlDB for stream processing, with many security features enabled, in an end-to-end streaming ETL pipeline with a source connector pulling from live data and a sink connector connecting to Elasticsearch and Kibana for visualizations. cp-demo also comes with a tutorial and is a great configuration reference for Confluent Platform.

<p align="center"><img src="https://raw.githubusercontent.com/confluentinc/cp-demo/5.4.1-post/docs/images/cp-demo-overview.jpg" width="600"></p>

Confluent Cloud

There are many examples from full end-to-end demos that create connectors, streams, and KSQL queries in Confluent Cloud, to resources that help you build your own demos. You can find the documentation and instructions for all Confluent Cloud demos at https://docs.confluent.io/platform/current/tutorials/examples/ccloud/docs/ccloud-demos-overview.html

| Demo | Local | Docker | Description | ------------------------------------------ | ----- | ------ | --------------------------------------------------------------------------- | Confluent CLI | Y | N | Fully automated demo interacting with your Confluent Cloud cluster using the Confluent CLI <br><img src="clients/cloud/images/confluent-cli.png" width="300"> | Clients in Various Languages to Cloud | Y | N | Client applications, showcasing producers and consumers, in various programming languages connecting to Confluent Cloud <br><img src="clients/cloud/images/clients-all.png" width="450"> | Cloud ETL | Y | N | Fully automated cloud ETL solution using Confluent Cloud connectors (AWS Kinesis, Postgres with AWS RDS, GCP GCS, AWS S3, Azure Blob) and fully-managed ksqlDB <br><img src="cloud-etl/docs/images/topology.png" width="450"> | ccloud-stack | Y | N | Creates a fully-managed stack in Confluent Cloud, including a new environment, service account, Kafka cluster, KSQL app, Schema Registry, and ACLs. The demo also generates a config file for use with client applications.<br><img src="https://github.com/confluentinc/cp-all-in-one/blob/latest/images/ccloud-stack-resources.png" width="300"> | On-Prem Kafka to Cloud | N | Y | Module 2 of Confluent Platform demo (cp-demo) with a playbook for copying data between the on-prem and Confluent Cloud clusters <br><img src="https://github.com/confluentinc/cp-demo/blob/8.0.0-post/docs/images/cp-demo-overview-with-ccloud.jpg" width="450"> | DevOps for Apache Kafka® with Kubernetes and GitOps | N | N | Simulated production environment running a streaming application targeting Apache Kafka on Confluent Cloud using Kubernetes and GitOps <br><img src="images/github-flux-kubernetes-600x105.png">

Stream Processing

| Demo | Local | Docker | Description | ------------------------------------------ | ----- | ------ | --------------------------------------------------------------------------- | Clickstream | N | Y | Automated version of the ksqlDB clickstream demo <br><img src="clickstream/docs/images/grafana-dashboard.png" width="450"> | Kafka Tutorials | Y | Y | Collection of common event streaming use cases, with each tutorial featuring an example scenario and several complete code solutions <br><img src="https://cdn.confluent.io/wp-content/uploads/Kafka-Tutorials-350x195.jpg" width="350"> | Microservices ecosystem | N | Y | Microservices orders Demo Application integrated into the Confluent Platform <br><img src="microservices-orders/docs/images/microservices-demo.jpg" width="450">

Data Pipelines

| Demo | Local | Docker | Description | ------------------------------------------ | ----- | ------ | --------------------------------------------------------------------------- | Clients in Various Languages | Y | N | Client applications, showcasing producers and consumers, in various programming languages <br><img src="clients/cloud/images/clients-all.png" width="450"> | Connect and Kafka Streams | Y | N | Demonstrate various ways, with and without Kafka Connect, to get data into Kafka topics and then loaded for use by the Kafka Streams API <br><img src="connect-streams-pipeline/docs/images/example_3.jpg" width="450">

Confluent Platform

| Demo | Local | Docker | Description | ------------------------------------------ | ----- | ------ | --------------------------------------------------------------------------- | Avro | Y | N | Client applications using Avro and Confluent Schema Registry <br><img src="https://www.confluent.io/wp-content/uploads/dwg_SchemaReg_howitworks.png" width="420"> | CP Demo | N | Y | Confluent Platform demo (cp-demo) with a playbook for Kafka event streaming ETL deployments <br><img src="https://github.com/confluentinc/cp-demo/blob/8.0.0-post/docs/images/cp-demo-overview.jpg" width="420"> | Kubernetes | N | Y | Demonstrations of Confluent Platform deployments using the Confluent Operator <br><img src="kubernetes/docs/images/operator.png" width="420"> | Multi Datacenter | N | Y | Active-active multi-datacenter design with two instances of Confluent Replicator copying data bidirectionally between the datacenters <br><img src="https://docs.confluent.io/platform/current/_images/mdc-level-1.png" width="420"> | Multi-Region Clusters | N | Y | Multi-Region clusters (MRC) with follower fetching, observers, and replica placement<br><img src="multiregion/docs/images/multi-region-topic-replicas-v2.png" width="420"> | Quickstart | Y | Y | Automated version of the Confluent Quickstart: for Confluent Platform on local install or Docker, community version, and Confluent Cloud <br><img src="cp-quickstart/images/quickstart.png" width="420"> | Role-Based Access Control | Y | Y | Role-based Access Control (R

View on GitHub
GitHub Stars2.0k
CategoryDevelopment
Updated4h ago
Forks1.1k

Languages

Java

Security Score

100/100

Audited on Mar 24, 2026

No findings