Apache Kafka, Apache Flink and Confluent Platform examples and demos

🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷‍♂️ Easily build examples or reproduction models

Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data

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

Integrated Docker Stack for the RADAR mHealth Streaming Platform Components

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

Multi Data Center Confluent Platform Setup with Replication - automated with Ansible

ネットワーク機器のログをSplunkのUniversal Forwarderを利用してConfluentに転送し、ストリーム処理後にSplunkのHECに転送するサンドボックス環境。

Vagrantfile to start a virtual machine running the confluent platform: Zookeeper, Kafka, Schema registry and Confluent control centre using cp-ansible

Ansible script to install Confluent platform without any pain

Chaos scenarios for Kafka 💥

Kafka Connect (JDBC Connector) を利用して、データベース (Postgres) から抽出したデータ更新イベントをKafkaに送る - この全体フローを横断的に観測

Confluent Cloud Kafka examples in Go

Use case simulations on ksqlDB (a database purpose-built for stream processing applications)

A Confluent platform environment using Vagrant

Fish shell completions file for the Confluent v2 CLI

Example migration from Strimzi to CFK

setup a multinode confluent stack incl. schema-registry and rest-proxy

This guide is to install Self-managed components like connectors with Docker, for testing. In this example I use Clickhouse as destination.