Confluent's Apache Kafka Golang client

Confluent Schema Registry for Kafka

Apache Kafka, Apache Flink and Confluent Platform examples and demos

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

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

Confluent's Kafka Python Client

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

Confluent's Apache Kafka JavaScript client

Golang Client for Schema Registry

Confluent's Apache Kafka .NET client

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

Streamline Apache Kafka with Conduktor Platform. 🚀

Confluent REST Proxy for Kafka

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

📊 Monitoring examples for Confluent Cloud and Confluent Platform

Gradle plugin to interact with Confluent Schema-Registry.

Kafka Connect FileSystem Connector

A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.

A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry

Manage Confluent Schema Registry subjects through Infrastructure as code

Practical examples with Apache Kafka®

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

JDBC driver for Apache Kafka

An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API

Interactive CLI for analyzing Kafka health and configuration according to best practices and industry standards.

Experiment with Kafka, Debezium, and ksqlDB. research-service: Performs MySQL record manipulation. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors and kafka-research-consumer: Listen to Kafka, insert/update Elasticsearch. ksqlDB-Server: Listens to Kafka, performs joins, and pushes new messages to new Kafka topics.

An event-driven monitoring tool that can consume messages from Apache Kafka clusters and display the aggregated data on a dashboard for analysis and maintenance.

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