Discover confluentinc/castle Open Source project

Confluent's Apache Kafka Golang client

5,533

confluent-kafka-go

4,402

confluent-kafka-python

Confluent's Kafka Python Client

Confluent's Apache Kafka .NET client

3,388

confluent-kafka-dotnet

2,560

kafka-streams-examples

Demo applications and code examples for Apache Kafka's Streams API.

Confluent REST Proxy for Kafka

2,169

kafka-rest

Confluent Schema Registry for Kafka

2,137

schema-registry

Apache Kafka and Confluent Platform examples and demos

2,022

examples

Change data capture from PostgreSQL into Kafka

1,903

bottledwater-pg

1,521

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/

[DEPRECATED] Docker images for Confluent Platform.

1,356

cp-docker-images

Kafka Connect connector for JDBC-compatible databases

1,142

kafka-connect-jdbc

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

953

cp-all-in-one

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

889

cp-helm-charts

Mustache

764

kafka-connect-elasticsearch

Kafka Connect Elasticsearch connector

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.

715

parallel-consumer

Kafka Connect HDFS connector

654

kafka-connect-hdfs

Tutorials and Recipes for Apache Kafka

465

kafka-tutorials

Confluent Docker images for Apache Kafka

302

kafka-images

System integration and performance tests

295

ducktape

The Apache Kafka C/C++ library

294

librdkafka

180

kafka-rest-node

Node.js client for the Kafka REST proxy

Security tools for the Confluent Platform.

146

confluent-platform-security-tools

Connector that generates data for demos

146

kafka-connect-datagen

DEPRECATED - Dockerfiles for Confluent Stream Data Platform

143

docker-images

Utilities and a small framework for building REST services with Jersey, Jackson, and Jetty.

116

rest-utils

CLI for Confluent Cloud and Confluent Platform

111

cli

103

openmessaging-benchmark

Mirror of Linkedin's Camus

camus

Common utilities library containing metrics, config and utils

common

kafka-workshop

Confluent's Apache Kafka JavaScript client

confluent-kafka-javascript

Source Code accompanying the Confluent Kafka for Developers course

training-developer-src

Running Tools from Confluent Platform along with your Confluent Cloud™ Cluster

ccloud-tools

Easily measure code coverage of Golang binaries

bincover

libserdes

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

kafka-connect-blog

Demo for Kafka Connect with JDBC and HDFS Connectors

confluent-cli

Confluent Platform CLI

Node.js GraphQL integration for ksqlDB

ksqldb-graphql

TypeScript

confluent-sigma

Confluent Cloud Terraform Provider is deprecated in favor of Confluent Terraform Provider

terraform-provider-confluentcloud

jmx-monitoring-stacks

📊 Monitoring examples for Confluent Cloud and Confluent Platform

confluent-kubernetes-examples

Example scenario workflows for Confluent for Kubernetes

Example online orders app composed of event-driven microservices. Built for QCon workshop.

qcon-microservices

Secure Kafka cluster (in a VM) for development and testing

securing-kafka-blog

Puppet

cp-demo

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

Contains docker-compose file needed for Apache Kafka Administration by Confluent training

training-administration-src

HTML

mox

A hybrid mock and proxy server - easily programmable and runs on express

Terraform module to create the S3/DynamoDB backend to store the Terraform state+lock

terraform-state-s3

Confluent Commons with support for building and testing Docker images.

common-docker

Files needed to try out KSQL Recipes for yourself

ksql-recipes-try-it-at-home

Sample solutions for the exercises of the course KSQL & Kafka Streams

training-ksql-and-streams-src

Docker Images for Schema Registry

schema-registry-images

Terraform Provider for Confluent

terraform-provider-confluent

confluent-docker-utils

Common Python utils for testing Confluent's Docker images

flink-cookbook

Ansible playbooks for the Confluent Platform

cp-ansible

Jinja

ksql-images

KSQL platform docker images

Source code for the "Coding in Motion" series.

coding-in-motion

Nix

proto-go-setter

online-inferencing-blog-application

Source code and application accompanying the online inferencing blog

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

stream-me-up-scotty

training-fundamentals-src

Source code accompanying the course "Apache Kafka Technical Essentials"

Code samples to go with InfoQ article

infoq-kafka-ksql

Docker Images for Kafka REST

kafka-rest-images

Confluent Docker images for Kafka MQTT

kafka-mqtt-images

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

learn-kafka-courses

Confluent Commercial SE Team's Demo and Workshop Repository

commercial-workshops

Source code accompanying the course "Monitoring, Troubleshooting and Tuning"

training-cao-src

Setup and testing connectivity to Confluent Cloud

ccloud-connectivity

A collection of Event Streaming Patterns, including problem statements, solutions, and implementation examples.

event-streaming-patterns

HTML

vscode

Confluent for Visual Studio Code

TypeScript

ksqldb-recipes

Makefile

ksql-workshop

KSQL Workshop

demo-stream-designer

Current 2022 Confluent Keynote Demo covering Stream Designer, Stream Catalog, and Stream Sharing.

Docker images for enterprise control center images

control-center-images

A demo target for running the Confluent HTTP sink connector

kafka-connect-http-demo

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).

demo-change-data-capture

Docker Images for Kafkacat

kafkacat-images

confluent-kafka-go-dev

[EXPERIMENTAL] Development / WIP / exploratory / test fork of confluent-kafka-go

confluent-hybrid-cloud-workshop

Confluent Hybrid Cloud Workshop

Content for Spring 2016 Strata tutorials

learn-practical-event-modeling

Kotlin

ksql-elasticsearch-demo

TSQL

strata-tutorials

This demo shows how to stream data to cloud databases with Confluent. It includes fully-managed connectors (Oracle CDC, RabbitMQ, MongoDB Atlas), ksqlDB/Flink SQL as stream processing engine.

demo-database-modernization

Java Examples for running Apache Flink® Table API on Confluent Cloud

flink-table-api-java-examples

confluent-oauth-extensions

Docker images for Kafka Connect

kafka-replicator-images

Code for ETL data pipelines

etl

Confluent Operator Early Access docs

operator-earlyaccess

schema-registry-workshop

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

Application modernization example including Confluent Cloud, ksqlDB, Postgres, and Elasticsearch.

demo-application-modernization

Enables use of external third-party systems for storing/retrieving key/value pairs with Confluent clusters.

csid-secrets-providers

Common utilities for metrics collection of proactive support

support-metrics-common

Python Examples for running Apache Flink® Table API on Confluent Cloud

flink-table-api-python-examples

Example application using the confluent-kafka-go client

confluent-kafka-go-example

learn-kafka-kraft

KRaft mode playground

SDK for interacting with Confluent Cloud

ccloud-sdk-go-v2

Makefile

100

streaming-ops

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