kafkastreams-cep
Complex Event Processor
A library that provides a DSL to select complex event sequences from Kafka Streams
Complex Event Processing on top of Kafka Streams
308 stars
21 watching
63 forks
Language: Java
last commit: 11 months ago
Linked from 1 awesome list
cepcomplex-event-processingkafkakafka-streams
Related projects:
Repository | Description | Stars |
---|---|---|
streamthoughts/kafka-connect-file-pulse | A tool that enables streaming and processing of various file formats into Apache Kafka | 324 |
line/decaton | A framework for high-throughput, concurrent task processing on Apache Kafka | 335 |
confluentinc/ksql | A database for real-time stream processing applications built on top of Apache Kafka. | 125 |
ibmstreams/streamsx.kafka | A toolkit for integrating Apache Kafka with Stream Processor SPL applications | 13 |
dcso/fever | A fast and extensible system for processing JSON events from security monitoring tools | 50 |
nmaquet/kasper | A lightweight library for processing Kafka topics with idempotent at-least-once semantics | 439 |
nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
fgeller/kt | A command-line tool for interacting with Apache Kafka clusters | 948 |
cyngn/vertx-kafka | A multi-threaded worker library that consumes Kafka messages and re-broadcasts them on the Vert.x event bus. | 30 |
morganstanley/modern-cpp-kafka | A C++ wrapper around librdkafka to simplify and improve Kafka client API usage | 359 |
devshawn/kafka-gitops | Automates Apache Kafka topic and ACL management through code-based configuration | 321 |
espertechinc/esper | A Java-based system for analyzing and reacting to patterns in event data streams | 840 |
siddhi-io/siddhi | A cloud-native streaming and complex event processing engine | 1,522 |
xitonix/trubka | A command-line tool for interacting with Kafka clusters | 333 |
wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for stream processing applications | 313 |