500 Open source projects that are alternatives of or similar to Ksql Recipes Try It At Home

Distributed Stream and Batch Processing

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.

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.

Fancy stream processing made operationally mundane

Python Stream Processing

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

A list about Apache Kafka

Source code for the Kafka Streams in Action Book

Ship changes in Postgres 🐘 to Kafka 📖

Golang Kafka consumer and producer example

Building event-driven applications the easy way in Go.

Kasper is a lightweight library for processing Kafka topics.

Neo4j Kafka Integrations, Docs =>

Kafka client for functional streams for scala (fs2)

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

Demo applications and code examples for Confluent Platform and Apache Kafka

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

light, fast, scalable, streaming microservices made easy

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

Kafka Tutorials microsite

Samsara is a real-time analytics platform

The database purpose-built for stream processing applications.

A lightweight stream processing library for Go

Kafka command line tool that likes JSON

A reliable, high-performance tool for building observability data pipelines.

SiteWhere is an industrial strength open-source application enablement platform for the Internet of Things (IoT). It provides a multi-tenant microservice-based infrastructure that includes device/asset management, data ingestion, big-data storage, and integration through a modern, scalable architecture. SiteWhere provides REST APIs for all system functionality. SiteWhere provides SDKs for many common device platforms including Android, iOS, Arduino, and any Java-capable platform such as Raspberry Pi rapidly accelerating the speed of innovation.

👾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/

Enterprise Network Flow Collector (IPFIX, sFlow, Netflow) from Verizon Media

Spring Boot 学习教程

CLI tools for monitoring and managing Apache Kafka

🐂基于springcloud +dubbo构建的模拟秒杀项目，模块化设计，集成了分库分表、elasticsearch🔍、gateway、mybatis-plus、spring-session等常用开源组件

Kubernetes Universal Declarative Operator (KUDO)

weiboAd Infrastructure Data Processor : kafka consumer embedded Lua scripting language in data process framework

A microservices-based Streaming and Batch data processing in Cloud Foundry and Kubernetes

必看！java后端，亮剑诛仙。java发展路线技术要点。

50+ DockerHub public images for Docker & Kubernetes - Hadoop, Kafka, ZooKeeper, HBase, Cassandra, Solr, SolrCloud, Presto, Apache Drill, Nifi, Spark, Consul, Riak, TeamCity and DevOps tools built on the major Linux distros: Alpine, CentOS, Debian, Fedora, Ubuntu

Streaming reference architecture for ETL with Kafka and Kafka-Connect. You can find more on http://lenses.io on how we provide a unified solution to manage your connectors, most advanced SQL engine for Kafka and Kafka Streams, cluster monitoring and alerting, and more.

Open source Observability Platform. 👉 SigNoz helps developers find issues in their deployed applications & solve them quickly

Demo for Redis Streams

Lightweight real-time big data streaming engine over Akka

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

This toolkit supports common internet protocols, such as HTTP and WebSockets

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

Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

High performance mqtt broker

This Scrapy project uses Redis and Kafka to create a distributed on demand scraping cluster.

Kafka Connect connector for JDBC-compatible databases

a fast and simple distributed publish-subscribe messaging system (mq)

A project for developing tutorials for Streams

Simple learning project pushing CSV data into Kafka then indexing the data in ElasticSearch

Kafka Connect Elasticsearch Source

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

Free and open source log management

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

An extensible distributed system for reliable nearline data streaming at scale

Fast and reliable message broker built on top of Kafka.

Apache Kafka support for Ruby Object Mapper

Read Kafka topics with WebSockets

Framework for building Event-Driven Microservices

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.