Topic: stream-processing

onurakpolat / awesome-bigdata

A curated list of awesome big data frameworks, ressources and other awesomeness.

awesome bigdata data-warehouse data-analytics data-visualization data-stream database data-science data awesome-list distributed-database series-database stream-processing streaming-data visualize-data

Updated Feb 12, 2019

robinhood / faust

3.1k

Python Stream Processing

kafka-streams kafka python asyncio distributed-systems stream-processing

Python Updated Apr 30, 2019

douban / dpark

2.5k

Python clone of Spark, a MapReduce alike framework in Python

bigdata mapreduce dpark stream-processing spark python

Python Updated Jan 23, 2019

confluentinc / ksql

2.2k

KSQL - the Streaming SQL Engine for Apache Kafka

stream-processing real-time sql interactive kafka

Java Updated May 1, 2019 4 issues need help

pipelinedb / pipelinedb

2.1k

High-performance time-series aggregation for PostgreSQL

realtime stream-processing analytics sql push postgresql pipelinedb time-series aggregation

C Updated Feb 22, 2019

Jeffail / benthos

1.8k

A stream processor for dull stuff written in Go

buffer message-queue bridge http-bridge pipeline multiplexer stream-processing streaming-data message-bus logs

Go Updated Apr 30, 2019 4 issues need help

francoispqt / gojay

1.6k

fastest JSON encoder/decoder with powerful stream API for Golang

go golang decoder encoder perfomance json stream-decoder stream-processing

Go Updated Apr 3, 2019

nerevu / riko

1.5k

A Python stream processing engine modeled after Yahoo! Pipes

stream-processing etl parallelism rss data asynchronous library cli functional-programming featured

Python Updated Feb 5, 2019 3 issues need help

WallarooLabs / wallaroo

1.3k

Distributed Stream Processing

stream-processing stream-processor stream-processing-engine pony-language python linux golang go framework api

Pony Updated Apr 30, 2019 19 issues need help

manuzhang / awesome-streaming

1.2k

a curated list of awesome streaming frameworks, applications, etc

awesome-list stream-processing awesome list

Updated Apr 11, 2019

gearpump / gearpump

694

Lightweight real-time big data streaming engine over Akka

akka stream-processing bigdata scala

Scala Updated Apr 8, 2019

siddhi-io / siddhi

676

Stream Processing and Complex Event Processing Engine

cep stream-processing complex-event-processing online-learning streaming-data-processing

Java Updated May 1, 2019 2 issues need help

spring-cloud / spring-cloud-dataflow

510

Spring Cloud Data Flow is a toolkit for building data integration and real-time data processing pipelines.

microservices-architecture orchestration stream-processing batch-processing predictive-analytics cloud-native portability

Java Updated Apr 30, 2019

spring-cloud / spring-cloud-stream

450

Event-Driven Microservices with Spring Integration

microservices messaging event-driven-microservices stream-processing reactive cloud-native

Java Updated Apr 29, 2019

edp963 / wormhole

428

Wormhole is a SPaaS (Stream Processing as a Service) Platform

wormhole stream-processing spark-streaming

JavaScript Updated Apr 29, 2019

nmaquet / kasper

372

Kasper is a lightweight library for processing Kafka topics.

golang-library kafka stream-processing

Go Updated Sep 16, 2017

nodefluent / kafka-streams

369

equivalent to kafka-streams 🐙 for nodejs ✨

🐢

🚀

✨

kafka streams stream-processing kafka-streams node nodejs big-data

JavaScript Updated Apr 18, 2019 2 issues need help

ThreeDotsLabs / watermill

356

Building event-driven applications easy way in Go.

watermill event-driven event-sourcing sagas events stream-processing reactive go golang rabbitmq kafka cqrs

Go Updated Apr 28, 2019

lw-lin / streaming-readings

351

Streaming System 相关的论文读物

stream-processing streaming flink spark-streaming storm heron dataflow drizzle millwheel s4 apache-spark streaming-engine spe stream-processing-engine

Updated Mar 31, 2018

hazelcast / hazelcast-jet

337

A general purpose distributed data processing engine, built on top of Hazelcast.

java in-memory data-grid big-data stream-processing batch-processing hazelcast-jet hazelcast

Java Updated May 1, 2019

vladimirvivien / automi

302

Stream processing API for Go (alpha)

golang go streaming-api stream-processing data-stream

Go Updated Apr 13, 2019

zhisheng17 / flink-learning

282

flink learning blog. http://www.54tianzhisheng.cn/tags/Flink/

flink kafka elasticsearch spark redis mysql rocketmq hbase rabbitmq stream-processing streaming

Java Updated Apr 30, 2019

infoslack / awesome-kafka

184

A list about Apache Kafka

kafka streaming-data data-pipeline stream-processing apache-kafka apache-spark kafka-streams infrastructure data-processing

Updated Jan 2, 2019

schollz / pluck

178

Pluck text in a fast and intuitive way 🐓

extract-information regex finite-state-machine stream-processing

Go Updated Jan 28, 2019

pemrouz / fero

171

light, fast, scalable, streaming microservices made easy

microservices kafka stream-processing scalable fast lightweight stateful

JavaScript Updated Apr 22, 2018

akka / akka-stream-contrib

146

Add-ons to Akka Stream

akka-streams akka stream-processing

Scala Updated Apr 16, 2019 2 issues need help

bytewatch / dolphinbeat

136

A server that pulls and parses MySQL binlog, pushs change data into different sinks like Kafka.

binlog change-data-capture pipeline stream-processing mysql mariadb mysql-kafka

Go Updated Jan 23, 2019

samsara / samsara

107

Samsara is a real-time analytics platform

realtime analytics clojure fast elasticsearch kafka stream-processing iot

Clojure Updated Feb 2, 2018 1 issue needs help

halaxa / json-machine

101

Efficient, easy-to-use and fast JSON pull parser

php stream-processing json-parser json-iterator json-stream parsing

PHP Updated Apr 10, 2019 1 issue needs help

vsouza / go-kafka-example

86

Golang Kafka consumer and producer example

golang kafka examples producer-consumer stream-processing

Go Updated Dec 13, 2018

stream-processing

Repositories 437