streamsx.topology

ibmstreams/streamsx.kafka13

Kafka integrator

A toolkit for integrating Apache Kafka with Stream Processor SPL applications

hortonworks/streamline165

Streaming Engine Framework

A toolset for building and deploying real-time data processing applications using various streaming engines and frameworks.

nanosai/stream-ops-java48

Streaming engine

A Java-based data streaming engine and stream processing API designed to be embeddable in various applications.

snapframework/io-streams99

Stream I/O library

Provides primitives and combinators for working with input/output streams in Haskell.

streamsets/datacollector-oss90

Data pipeline tool

A continuous big data ingestion platform that enables easy creation of data pipelines for various data sources and destinations.

jpcik/morph-streams16

Stream processor

A tool for processing and analyzing continuous data streams using query languages

sirthias/swave171

Streaming toolkit

A toolkit for building high-performance streaming applications in Scala

thomasjkeel/jsmetrics25

Jet stream analyzer

A Python package providing algorithms and metrics to analyze atmospheric jet streams

apache/streampipes614

Data pipeline manager

A toolbox for industrial data analytics and stream processing

vitaut/_._131

Stream wrapper

A simple library providing a shorthand notation for using input/output streams.

gazette/core723

Streaming platform

Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms

quixio/quix-streams1.2K

Data processor

A Python framework for real-time data processing on Apache Kafka streams

jooq/jool2.1K

Stream processor

Extends Java 8 lambdas with additional functionality for working with sequential data streams

scikit-multiflow/scikit-multiflow766

Machine Learning Platform

A machine learning package for streaming data in Python.

apache/rocketmq-streams172

Stream processor

Provides a lightweight stream processing framework