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

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.

Grid Solutions Framework

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

Open Source Phasor Data Concentrator

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

opensource distributed SQL database with base JPA implementation and CEP support

A Stream Processing Library for Go

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 platform for collecting, storing, and processing time series at scale

Kafka Complex Event Processing Engine

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.

Control Structures and Paradigms in Java on the JVM

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

Collection of tools to work with TIBCO BusinessEvents

Flink CEP combined with PA model

Implementation of an event processing framework within a DPDK accelerated Open vSwitch. The implemented framework embeds the vSwitch with capabilities to detect and process L7 events based on configured event rules. Additionally, an SDN controller based northbound API is implemented to offload application rules onto the vSwitch remotely.

A Complex Event Processing engine for the identification of events related to the resource usage of deployed services.

Apama Connectivity Plugin for Apache Pulsar Messaging Framework.

Complex event processing engine for IR4 workloads