• Stars
    star
    1,878
  • Rank 24,481 (Top 0.5 %)
  • Language
    Shell
  • License
    Apache License 2.0
  • Created over 6 years ago
  • Updated 2 months ago

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

Apache Kafka and Confluent Platform examples and demos

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.

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.

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
Clients in Various Languages to Cloud Y N Client applications, showcasing producers and consumers, in various programming languages connecting to Confluent Cloud
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
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.
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
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

Stream Processing

Demo Local Docker Description
Clickstream N Y Automated version of the ksqlDB clickstream demo
Kafka Tutorials Y Y Collection of common event streaming use cases, with each tutorial featuring an example scenario and several complete code solutions
Microservices ecosystem N Y Microservices orders Demo Application integrated into the Confluent Platform

Data Pipelines

Demo Local Docker Description
Clients in Various Languages Y N Client applications, showcasing producers and consumers, in various programming languages
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

Confluent Platform

Demo Local Docker Description
Avro Y N Client applications using Avro and Confluent Schema Registry
CP Demo N Y Confluent Platform demo (cp-demo) with a playbook for Kafka event streaming ETL deployments
Kubernetes N Y Demonstrations of Confluent Platform deployments using the Confluent Operator
Multi Datacenter N Y Active-active multi-datacenter design with two instances of Confluent Replicator copying data bidirectionally between the datacenters
Multi-Region Clusters N Y Multi-Region clusters (MRC) with follower fetching, observers, and replica placement
Quickstart Y Y Automated version of the Confluent Quickstart: for Confluent Platform on local install or Docker, community version, and Confluent Cloud
Role-Based Access Control Y Y Role-based Access Control (RBAC) provides granular privileges for users and service accounts
Replicator Security N Y Demos of various security configurations supported by Confluent Replicator and examples of how to implement them

Build Your Own

As a next step, you may want to build your own custom demo or test environment. We have several resources that launch just the services in Confluent Cloud or on prem, with no pre-configured connectors, data sources, topics, schemas, etc. Using these as a foundation, you can then add any connectors or applications. You can find the documentation and instructions for these "build-your-own" resources at https://docs.confluent.io/platform/current/tutorials/build-your-own-demos.html.

Additional Demos

Here are additional GitHub repos that offer an incredible set of nearly a hundred other Apache Kafka demos. They are not maintained on a per-release basis like the demos in this repo, but they are an invaluable resource.

More Repositories

1

librdkafka

The Apache Kafka C/C++ library
C
7,353
star
2

ksql

The database purpose-built for stream processing applications.
Java
5,533
star
3

confluent-kafka-go

Confluent's Apache Kafka Golang client
Go
4,402
star
4

confluent-kafka-python

Confluent's Kafka Python Client
Python
3,388
star
5

confluent-kafka-dotnet

Confluent's Apache Kafka .NET client
C#
2,560
star
6

kafka-streams-examples

Demo applications and code examples for Apache Kafka's Streams API.
Java
2,169
star
7

kafka-rest

Confluent REST Proxy for Kafka
Java
2,137
star
8

schema-registry

Confluent Schema Registry for Kafka
Java
2,022
star
9

bottledwater-pg

Change data capture from PostgreSQL into Kafka
C
1,521
star
10

demo-scene

👾Scripts and samples to support Confluent Demos and Talks. ⚠️Might be rough around the edges ;-) 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/
Shell
1,356
star
11

cp-docker-images

[DEPRECATED] Docker images for Confluent Platform.
Python
1,143
star
12

kafka-connect-jdbc

Kafka Connect connector for JDBC-compatible databases
Java
953
star
13

cp-all-in-one

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud, Apache Kafka Confluent Platform
Python
889
star
14

cp-helm-charts

The Confluent Platform Helm charts enable you to deploy Confluent Platform services on Kubernetes for development, test, and proof of concept environments.
Mustache
764
star
15

kafka-connect-elasticsearch

Kafka Connect Elasticsearch connector
Java
715
star
16

parallel-consumer

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.
Java
654
star
17

kafka-connect-hdfs

Kafka Connect HDFS connector
Java
465
star
18

kafka-tutorials

Tutorials and Recipes for Apache Kafka
Java
302
star
19

kafka-images

Confluent Docker images for Apache Kafka
Python
295
star
20

ducktape

System integration and performance tests
Python
294
star
21

kafka-rest-node

Node.js client for the Kafka REST proxy
JavaScript
146
star
22

confluent-platform-security-tools

Security tools for the Confluent Platform.
Shell
146
star
23

kafka-connect-datagen

Connector that generates data for demos
Java
143
star
24

docker-images

DEPRECATED - Dockerfiles for Confluent Stream Data Platform
Shell
116
star
25

rest-utils

Utilities and a small framework for building REST services with Jersey, Jackson, and Jetty.
Java
111
star
26

cli

CLI for Confluent Cloud and Confluent Platform
Go
103
star
27

openmessaging-benchmark

Java
89
star
28

camus

Mirror of Linkedin's Camus
Java
88
star
29

common

Common utilities library containing metrics, config and utils
Java
85
star
30

kafka-workshop

JavaScript
75
star
31

training-developer-src

Source Code accompanying the Confluent Kafka for Developers course
Java
70
star
32

ccloud-tools

Running Tools from Confluent Platform along with your Confluent Cloud™ Cluster
HCL
67
star
33

bincover

Easily measure code coverage of Golang binaries
Go
62
star
34

libserdes

Avro Serialization/Deserialization C/C++ library with Confluent schema-registry support
C
62
star
35

kafka-connect-blog

Demo for Kafka Connect with JDBC and HDFS Connectors
Shell
59
star
36

confluent-cli

Confluent Platform CLI
Shell
58
star
37

ksqldb-graphql

Node.js GraphQL integration for ksqlDB
TypeScript
56
star
38

terraform-provider-confluentcloud

Confluent Cloud Terraform Provider is deprecated in favor of Confluent Terraform Provider
Go
52
star
39

confluent-sigma

JavaScript
50
star
40

jmx-monitoring-stacks

📊 Monitoring examples for Confluent Cloud and Confluent Platform
C#
44
star
41

qcon-microservices

Example online orders app composed of event-driven microservices. Built for QCon workshop.
Java
38
star
42

securing-kafka-blog

Secure Kafka cluster (in a VM) for development and testing
Puppet
38
star
43

training-administration-src

Contains docker-compose file needed for Apache Kafka Administration by Confluent training
HTML
36
star
44

mox

A hybrid mock and proxy server - easily programmable and runs on express
JavaScript
35
star
45

terraform-state-s3

Terraform module to create the S3/DynamoDB backend to store the Terraform state+lock
HCL
34
star
46

common-docker

Confluent Commons with support for building and testing Docker images.
Java
34
star
47

ksql-recipes-try-it-at-home

Files needed to try out KSQL Recipes for yourself
Shell
34
star
48

cp-demo

Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Schema Registry, Security, Schema Linking, and Cluster Linking
Shell
31
star
49

confluent-kubernetes-examples

Example scenario workflows for Confluent for Kubernetes
Shell
31
star
50

training-ksql-and-streams-src

Sample solutions for the exercises of the course KSQL & Kafka Streams
Java
30
star
51

schema-registry-images

Docker Images for Schema Registry
Python
29
star
52

confluent-docker-utils

Common Python utils for testing Confluent's Docker images
Python
28
star
53

cp-ansible

Ansible playbooks for the Confluent Platform
Jinja
28
star
54

ksql-images

KSQL platform docker images
Shell
27
star
55

proto-go-setter

Go
23
star
56

coding-in-motion

Source code for the "Coding in Motion" series.
Nix
23
star
57

online-inferencing-blog-application

Source code and application accompanying the online inferencing blog
Java
21
star
58

stream-me-up-scotty

A wide range of Digital Assets from Confluent's Solution Engineering team for Confluent Cloud
21
star
59

terraform-provider-confluent

Terraform Provider for Confluent
Go
21
star
60

training-fundamentals-src

Source code accompanying the course "Apache Kafka Technical Essentials"
Shell
19
star
61

infoq-kafka-ksql

Code samples to go with InfoQ article
Shell
17
star
62

kafka-rest-images

Docker Images for Kafka REST
Python
17
star
63

flink-cookbook

Java
17
star
64

confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client
JavaScript
17
star
65

kafka-mqtt-images

Confluent Docker images for Kafka MQTT
Shell
16
star
66

demo-realtime-data-warehousing

Streaming data pipelines for real-time data warehousing. Includes fully managed connectors (PostgreSQL CDC, Snowflake).
HCL
14
star
67

training-cao-src

Source code accompanying the course "Monitoring, Troubleshooting and Tuning"
Java
13
star
68

event-streaming-patterns

A collection of Event Streaming Patterns, including problem statements, solutions, and implementation examples.
HTML
13
star
69

ccloud-connectivity

Setup and testing connectivity to Confluent Cloud
Shell
13
star
70

learn-building-flink-applications-in-java-exercises

Java
13
star
71

ksqldb-recipes

Makefile
11
star
72

ksql-workshop

KSQL Workshop
11
star
73

control-center-images

Docker images for enterprise control center images
Python
11
star
74

kafka-connect-http-demo

A demo target for running the Confluent HTTP sink connector
Java
11
star
75

castle

Castle is a test harness for Apache Kafka, Trogdor, and related projects.
Java
11
star
76

kafkacat-images

Docker Images for Kafkacat
10
star
77

demo-stream-designer

Current 2022 Confluent Keynote Demo covering Stream Designer, Stream Catalog, and Stream Sharing.
Python
10
star
78

confluent-kafka-go-dev

[EXPERIMENTAL] Development / WIP / exploratory / test fork of confluent-kafka-go
Go
10
star
79

demo-change-data-capture

This demo shows how to capture data changes from relational databases (Oracle and PostgreSQL) and stream them to Confluent Cloud, use ksqlDB for real-time stream processing, send enriched data to cloud data warehouses (Snowflake and Amazon Redshift).
HCL
10
star
80

confluent-hybrid-cloud-workshop

Confluent Hybrid Cloud Workshop
HCL
10
star
81

commercial-workshops

Confluent Commercial SE Team's Demo and Workshop Repository
Python
9
star
82

learn-kafka-courses

Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.
Shell
9
star
83

hackathons

Contains skeleton projects for hackathons.
Python
8
star
84

ksql-elasticsearch-demo

TSQL
8
star
85

learn-practical-event-modeling

Kotlin
8
star
86

strata-tutorials

Content for Spring 2016 Strata tutorials
Java
7
star
87

learn-apache-kafka-for-dotnet-developers-exercises

C#
7
star
88

confluent-oauth-extensions

Java
6
star
89

kafka-replicator-images

Docker images for Kafka Connect
Shell
6
star
90

etl

Code for ETL data pipelines
Python
6
star
91

operator-earlyaccess

Confluent Operator Early Access docs
6
star
92

schema-registry-workshop

JavaScript
6
star
93

support-metrics-common

Common utilities for metrics collection of proactive support
Java
6
star
94

confluent-kafka-go-example

Example application using the confluent-kafka-go client
Go
5
star
95

streaming-ops

Simulated production environment running Kubernetes targeting Apache Kafka and Confluent components on Confluent Cloud. Managed by declarative infrastructure and GitOps.
Shell
5
star
96

learn-kafka-connect

Shell
4
star
97

support-metrics-client

The client application that powers metrics collection for pro-active support
Java
4
star
98

avro-cpp-packaging

Avro C++ library packaging
C++
4
star
99

aws-confluent

Public repository for Confluent on AWS related material.
4
star
100

qcon-ai-workshop

Exercises for QCon Workshop
JavaScript
4
star