teknek-core

Stream processor

A software platform that enables stream processing and data integration across multiple data sources.

The core libraries of the teknek stream processing platform

GitHub

8 stars
3 watching
1 forks
Language: Java
last commit: almost 9 years ago
Linked from 1 awesome list


Backlinks from these awesome lists:

Related projects:

Repository Description Stars
jpcik/morph-streams A tool for processing and analyzing continuous data streams using query languages 16
nerevu/riko A Python library for analyzing and processing streams of structured data 1,604
keilerkonzept/topk An implementation of probabilistic data structures for approximate data stream processing 4
gojek/ziggurat A framework for building stateless applications on top of Kafka stream processing 398
confluentinc/ksql A database for real-time stream processing applications built on top of Apache Kafka. 125
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
bkirwi/coast A streaming data processing framework with strong ordering and exactly-once semantics 60
wintoncode/winton-kafka-streams A Python implementation of Apache Kafka's Streams API for stream processing applications 313
maki-nage/makinage Stream Processing Library and Framework 39
leepike/copilot A language and toolset for generating hard real-time C code from a domain-specific stream language 149
knowledgeonwebscale/streamingmassif A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing. 9
nodefluent/kafka-streams A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. 831
lmco/streamflow A tool designed to simplify stream processing workflow development and management 253
streampunk/beamcoder Provides Node.js bindings to FFmpeg for media processing and manipulation 399
scramjetorg/framework-js A reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams. 38