53 Open Source Confluent Software Projects
Free and open source confluent code projects including engines, APIs, generators, and tools.
Ksql Udf Deep Learning Mqtt Iot 248 ⭐
Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data
Cp Demo 361 ⭐
Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Replicator, Confluent Schema Registry, Security
Hivemq Mqtt Tensorflow Kafka Realtime Iot Machine Learning Training Inference 260 ⭐
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
Kafka Connect Iot Mqtt Connector Example 165 ⭐
Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
Lensesio Schema Registry 111 ⭐
A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.
Tensorflow Serving Java Grpc Kafka Streams 121 ⭐
Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
Kafka Shell 102 ⭐
⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.
Open Bank Mark 87 ⭐
A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.
Orleans.streams.kafka 48 ⭐
An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API
Springboot Kafka Connect Streams 61 ⭐
The main goal is to play with Kafka Connect and Streams. We have store-api that inserts/updates records in MySQL; Source connectors that monitor inserted/updated records in MySQL and push messages related to those changes to Kafka; Sink connectors that read messages from Kafka and insert documents in ES; Store-streams that listens for messages in Kafka, treats them using Kafka Streams and push new messages back to Kafka.
Kafka Connect Storage Common 43 ⭐
Shared software among connectors that target distributed filesystems and cloud storage.
Awesome Kafka In Clojure 26 ⭐
Awesome information for using Kafka and Confluent Platform in Clojure.
Schema Registry Php Client 35 ⭐
A PHP 7.3+ API client for the Confluent Schema Registry REST API based on Guzzle 6 - http://docs.confluent.io/current/schema-registry/docs/index.html
Schema Registry Transfer Smt 33 ⭐
Kafka Connect Transform to copy Avro schemas between Schema Registries
Springboot Kafka Avro 30 ⭐
A simple Spring Boot app that talks to Kafka using Avro and Schema Registry
Confluent Spark Avro 18 ⭐
Spark UDFs to deserialize Avro messages with schemas stored in Schema Registry.
Springboot Kafka Debezium Ksql 39 ⭐
The goal of this project is to play with Kafka, Debezium and ksqlDB. For this, we have: research-service that inserts/updates/deletes records in MySQL; Source Connectors that monitor change of records in MySQL and push messages related to those changes to Kafka; Sink Connectors and kafka-research-consumer that listen messages from Kafka and insert/update documents in Elasticsearch; finally, ksqlDB-Server that listens to some topics in Kafka, does some joins and pushes new messages to new topics in Kafka.
Avro Serde Php 33 ⭐
Avro Serialisation/Deserialisation (SerDe) library for PHP 7.3+ & 8.0 with a Symfony Serializer integration
Confluent Windows 5.0.1 10 ⭐
This is window compatible confluent platform which can be run with one command
Confluent Platform Spark Streaming 11 ⭐
Working example of consuming Avro data from Kafka with Spark Streaming
Confluent Kafka Role 11 ⭐
Highly configurable Ansible role to Install and manage Apache Kafka and Apache Zookeeper "from scratch" using Confluent package
Kafkaesk 78 ⭐
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.
Streaming Ops 55 ⭐
Simulated production environment running Kubernetes targeting Apache Kafka and Confluent components on Confluent Cloud. Managed by declarative infrastructure and GitOps.
Schema Registry Gitops 23 ⭐
Manage Confluent Schema Registry subjects through Infrastructure as code