streamline
Streaming Engine Framework
A toolset for building and deploying real-time data processing applications using various streaming engines and frameworks.
StreamLine - Streaming Analytics
165 stars
685 watching
95 forks
Language: Java
last commit: over 1 year ago
Linked from 1 awesome list
flinkkafkakafka-streamsreal-timespark-streamingstormstreaming
manuzhang/awesome-streamingRelated projects:
| Repository | Description | Stars |
|---|---|---|
 ibmstreams/streamsx.topology | A collection of tools and templates for building streaming applications on IBM Streams using various programming languages. | 29 |
 streampunk/node-red-contrib-dynamorse-core | A software framework that enables the creation of streaming workflows on commodity IT systems using reactive streams and NMOS registration/discovery. | 45 |
 streamthoughts/kafka-connect-file-pulse | A tool that enables streaming and processing of various file formats into Apache Kafka | 324 |
| ibmstreams/streamsx.kafka | A toolkit for integrating Apache Kafka with Stream Processor SPL applications | 13 |
 nanosai/stream-ops-java | A Java-based data streaming engine and stream processing API designed to be embeddable in various applications. | 48 |
 composewell/streamly | A high-performance Haskell library providing functional programming abstractions and concurrency capabilities | 873 |
 javactrl/javactrl-kafka | A tool for defining and managing workflows as code on top of Apache Kafka Streams | 9 |
 gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 723 |
 yannael/kafka-sparkstreaming-cassandra | An environment for experimenting with real-time data processing using Kafka, Spark streaming, and Cassandra | 97 |
 nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
 olacabs/fabric | A real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability. | 55 |
 nfroidure/streamqueue | Manages and pipes queued streams sequentially to preserve content order. | 63 |
 scramjetorg/framework-js | A reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams. | 38 |
 raystack/firehose | Delivers real-time streaming data to various destinations | 329 |
 snapframework/io-streams | Provides primitives and combinators for working with input/output streams in Haskell. | 99 |