Stream Processing and Complex Event Processing Engine

Esper Complex Event Processing, Streaming SQL and Event Series Analysis

Complex Event Processing on top of Kafka Streams

Complex event processing in Erlang

Wayeb is a Complex Event Processing and Forecasting (CEP/F) engine written in Scala.

Grid Solutions Framework

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.

Real time data processing system based on flink and CEP

Open Source Phasor Data Concentrator

Simple demo of some features of the Esper Complex Event Processing (CEP) engine.

An open source, cloud-native streaming data integration and analytics product optimized for agile digital businesses

opensource distributed database with base JPA implementation and event processing support

A Stream Processing Library for Go

RTEC is an Event Calculus implementation optimised for stream reasoning

Small and simple stream-based CEP tool for IoT devices connected to an MQTT broker

An overview of Complex Event Processing Systems

Distributed stream processing layer

Complex event processing engine for time series data

A Stream Processing Service written in Go

This is the repository of the ElasTest Monitoring Service, which provides a monitoring infrastructure suitable for inspecting executions of a SuT (System under Test) and the ElasTest platform itself online.

An adaptive and self-boosting stream processor

Bei diesem Projekt handelt es sich um ein Forschungsprojekt der Hochschule der Medien, Stuttgart.

A fault-tolerant complex event processing engine designed for edge computing in IoT systems.

Collection of tools to work with TIBCO BusinessEvents

Event oriented high performance time-series database and messaging middleware

Control Structures and Paradigms in Java on the JVM

https://github.com/deib-polimi/TRex. T-Rex is a general-purpose Complex Event Processing (CEP) Infrastructure designed to support an expressive language for rule definition while offering efficient processing mechanisms. This repository provides T-Rex engine in Java.

Flink CEP combined with PA model