44 Open Source Confluent Software Projects
Free and open source confluent code projects including engines, APIs, generators, and tools.
Ksql Udf Deep Learning Mqtt Iot 204 ⭐
Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data
Cp Demo 219 ⭐
Confluent Platform Demo including Apache Kafka, KSQL, Control Center, Replicator, Confluent Schema Registry, Security
Hivemq Mqtt Tensorflow Kafka Realtime Iot Machine Learning Training Inference 153 ⭐
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 109 ⭐
Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
Tensorflow Serving Java Grpc Kafka Streams 97 ⭐
Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
Kafka Shell 81 ⭐
⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.
Open Bank Mark 76 ⭐
A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.
Orleans.streams.kafka 36 ⭐
An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API
Springboot Kafka Connect Streams 33 ⭐
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 29 ⭐
Shared software among connectors that target distributed filesystems and cloud storage.
Awesome Kafka In Clojure 25 ⭐
Awesome information for using Kafka and Confluent Platform in Clojure.
Schema Registry Php Client 24 ⭐
A PHP 7.2+ 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 22 ⭐
Kafka Connect Transform to copy Avro schemas between Schema Registries
Springboot Kafka Avro 18 ⭐
A simple Spring Boot app that talks to Kafka using Avro and Schema Registry
Confluent Spark Avro 17 ⭐
Spark UDFs to deserialize Avro messages with schemas stored in Schema Registry.
Springboot Kafka Debezium Ksql 19 ⭐
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 17 ⭐
Avro Serialisation/Deserialisation (SerDe) library for PHP 7.2+ with a Symfony Serializer integration
Confluent Windows 5.0.1 11 ⭐
This is window compatible confluent platform which can be run with one command
Confluent Platform Spark Streaming 10 ⭐
Working example of consuming Avro data from Kafka with Spark Streaming