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 11 years ago
Linked from 1 awesome list


Backlinks from these awesome lists:

Related projects:

RepositoryDescriptionStars
jpcik/morph-streamsA tool for processing and analyzing continuous data streams using query languages16
nerevu/rikoA Python library for analyzing and processing streams of structured data1,605
keilerkonzept/topkAn implementation of probabilistic data structures for approximate data stream processing4
gojek/zigguratA framework for building stateless applications on top of Kafka stream processing399
confluentinc/ksqlA database for real-time stream processing applications built on top of Apache Kafka.133
olacabs/fabricA real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability.55
bkirwi/coastA streaming data processing framework with strong ordering and exactly-once semantics60
wintoncode/winton-kafka-streamsA Python implementation of Apache Kafka's Streams API for building stream processing applications311
maki-nage/makinageStream Processing Library and Framework38
leepike/copilotA language and toolset for generating hard real-time C code from a domain-specific stream language149
knowledgeonwebscale/streamingmassifA Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing.10
nodefluent/kafka-streamsA Node.js library implementing Kafka Streams functionality for stream state processing and table representation.831
lmco/streamflowA tool designed to simplify stream processing workflow development and management253
streampunk/beamcoderProvides Node.js bindings to FFmpeg for media processing and manipulation401
scramjetorg/framework-jsA reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams.38