smartloli / kafka-eagle

Star

A easy and high-performance monitoring system, as well as offsets or metadata and other kafka information.

kafka zookeeper offsets consumer-group kafka-eagle kafka-sql ksql

Updated Jul 26, 2020
Java

confluentinc / examples

Star

Apache Kafka and Confluent Platform examples and demos

Updated Jul 24, 2020
Shell

xaecbd / KafkaCenter

Star

KafkaCenter is a unified one-stop platform for Kafka cluster management and maintenance, producer / consumer monitoring, and use of ecological components.

kafka kafka-connect kafka-manager kafka-monitor kafka-eagle ksql connect-ui kafkacenter kafkamanager kafka-center kmanager kafkaoffsetmonitor kafka-connect-ui

Updated Jul 15, 2020
Java

kaiwaehner / kafka-streams-machine-learning-examples

Star

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

python java open-source machine-learning kafka deep-learning tensorflow h2o keras kafka-client kafka-streams dl4j keras-tensorflow h2oai deeplearning4j ksql

Updated Apr 23, 2020
Java

confluentinc / demo-scene

Star

Scripts and samples to support Confluent Platform talks. May be rough around the edges. For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/

mysql elasticsearch kafka syslog kafka-connect kafka-streams debezium ksql

Updated Jul 24, 2020
Shell

confluentinc / cp-helm-charts

Star

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

kubernetes helm zookeeper helm-charts kafka-connect apache-kafka kafka-rest-proxy statefulsets ksql ksql-server

Updated Jul 20, 2020
Smarty

confluentinc / cp-ansible

Star

Ansible playbooks for the Confluent Platform

ansible kafka schema-registry playbook confluent kafka-connect ksql rest-proxy

Updated Jul 25, 2020
Python

kaiwaehner / ksql-udf-deep-learning-mqtt-iot

Star

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

java open-source mqtt machine-learning kafka deep-learning tensorflow confluent kafka-connect kafka-client h2oai ksql confluent-platform

Updated Apr 22, 2020
Java

confluentinc / cp-demo

Star

Confluent Platform Demo including Apache Kafka, KSQL, Control Center, Replicator, Confluent Schema Registry, Security

ssl security demo kafka sasl confluent connect ksql confluent-platform

Updated Jul 22, 2020
Shell

framiere / a-kafka-story

Star

Kafka ecosystem ... but step by step!

kafka zookeeper kafka-streams cdc kafka-broker debezium ksql

Updated Jul 1, 2020
Java

kaiwaehner / hivemq-mqtt-tensorflow-kafka-realtime-iot-machine-learning-training-inference

Star

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

Updated Apr 6, 2020
Jupyter Notebook

mtpatter / postgres-kafka-demo

Star

Fully reproducible step-by-step demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres

streaming kafka postgresql kafka-connect debezium ksql ksql-server

Updated Mar 12, 2019
Dockerfile

bryanyang0528 / ksql-python

Star

A python wrapper for the KSQL REST API.

python api kafka ksql

Updated Jul 26, 2020
Python

mmolimar / ksql-jdbc-driver

Star

JDBC driver for Apache Kafka

kafka jdbc driver confluent apache-kafka ksql ksqldb

Updated Jan 20, 2020
Scala

kaiwaehner / ksql-fork-with-deep-learning-function

Star

Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example

kafka deep-learning stream h2o udf ksql ksql-server ksql-udf kafka-ecosystem

Updated Jul 31, 2018
Java

matsumana / tsujun

Star

Yet another Web UI for KSQL

kafka kafka-streams ksql

Updated Jul 30, 2018
Kotlin

confluentinc / ksql-recipes-try-it-at-home

Star

Files needed to try out KSQL Recipes for yourself

kafka stream-processing ksql

Updated Apr 12, 2019
Shell

ticean / awesome-kafka-in-clojure

Star

Awesome information for using Kafka and Confluent Platform in Clojure.

clojure awesome microservices kafka avro confluent awesome-list kafka-connect microservices-architecture kafka-streams avro-schema awesome-lists ksql confluent-platform

Updated May 29, 2019

kaiwaehner / iiot-integration-apache-plc4x-kafka-connect-ksql-opc-ua-modbus-siemens-s7

Star

Industrial IoT (IIoT) Integration and Data Processing with Apache PLC4X, Kafka Connect, KSQL (OPC-UA, Modbus, Siemens S7)

iot middleware kafka integration modbus iot-platform kafka-connect iiot opc-ua iot-framework allen-bradley ksql siemens-s7

Updated Aug 30, 2019

ivangfr / springboot-kafka-debezium-ksql

Star

The goal is to play with Debezium and KSQL. 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 read messages from Kafka and insert/update documents in Elasticsearch; finally, KSQL-Server that listens some topics in Kafka, does some joins and pushes new messages to new topics in Kafka.