1776 Open source projects that are alternatives of or similar to Ksql

A high performance/ real-time C++ Kafka streams framework (C++17)

Demo applications and code examples for Confluent Platform and Apache Kafka

OmniSciDB (formerly MapD Core)

A REPL for Apache Kafka

Kafka client for functional streams for scala (fs2)

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

Kafka Tutorials microsite

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

MongoDB Kafka Connector

Source code for the Kafka Streams in Action Book

pmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].

Kattlo CLI Project

Ship changes in Postgres 🐘 to Kafka 📖

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

Protobuf converter plugin for Kafka Connect

Samsara is a real-time analytics platform

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

Kasper is a lightweight library for processing Kafka topics.

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

Building event-driven applications the easy way in Go.

Open-Source Web GUI for Apache Kafka Management

Elastic data processing with Apache Pulsar and Apache Flink

High-performance time-series aggregation for PostgreSQL

TouchDesigner toxes and small projects

Materialize lets you ask questions of your live data, which it answers and then maintains for you as your data continue to change. The moment you need a refreshed answer, you can get it in milliseconds. Materialize is designed to help you interactively explore your streaming data, perform data warehousing analytics against live relational data, or just increase the freshness and reduce the load of your dashboard and monitoring tasks.

ARTML- Real time learning

A list about Apache Kafka

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

[DEPRECATED] Docker images for Confluent Platform.

Example end to end data engineering project.

Massively real-time traffic streaming application

Kafka Source Connector For Oracle

equivalent to kafka-connect 🔧 for nodejs ✨🐢🚀✨

Files needed to try out KSQL Recipes for yourself

Neo4j Kafka Integrations, Docs =>

Kafka Connect Tooling

Playground for Kafka/Confluent Docker experimentations

Golang Kafka consumer and producer example

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

StreamLine - Streaming Analytics

Web tool for Kafka Connect |

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

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

Apache Kafka running on Kubernetes

The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.

面向 OLTP、OLAP、批处理、流处理场景的大一统 SQL 引擎

light, fast, scalable, streaming microservices made easy

Ansible playbooks for the Confluent Platform

TalariaDB is a distributed, highly available, and low latency time-series database for Presto

Simple shared surface streaming application

Flexible and efficient data processing engine and an evolution of the popular Scramjet Framework based on node.js. Our Transform Hub was designed specifically for data processing and has its own unique algorithms included.

Draw new worlds

Kafka connect Elastic sink connector, with just in time index/delete behaviour.

Distributed Stream and Batch Processing

Mirus is a cross data-center data replication tool for Apache Kafka

Event-Driven microservices with Kafka Streams

Fancy stream processing made operationally mundane

Get a stream of issues and pull requests for your chosen GitHub repository