ksql

A easy and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.

Apache Kafka and Confluent Platform examples and demos

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

👾Scripts and samples to support Confluent Demos and Talks. ⚠️Might be rough around the edges ;-) 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/

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.

Ansible playbooks for the Confluent Platform

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

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

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 ecosystem ... but step by step!

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

A python wrapper for the KSQL REST API.

JDBC driver for Apache Kafka

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

Yet another Web UI for KSQL

Files needed to try out KSQL Recipes for yourself

Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala

Awesome information for using Kafka and Confluent Platform in Clojure.

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

Geospatial UDFs for KSQL

Built a stream processing data pipeline to get data from disparate systems into a dashboard using Kafka as an intermediary.

Code samples to go with InfoQ article

Apache Kafka / Confluent KSQL REST Client for PHP

Kafka.DotNet.ksqlDB is a C# LINQ-enabled client API for issuing and consuming ksqlDB push queries and executing statements. Kafka.DotNet.SqlServer is a client API for consuming row-level table changes (CDC - Change Data Capture) from Sql Server databases with the Debezium connector streaming platform.

A barebones go client for interacting with Confluent's KSQL Server

Let's Learn ksqlDB

The Asynchronous PHP KSQL Connector

Terraform provider for managing KSQL queries

Twitter dashboard analyzing certain topics with angular, confluent and node