timeplus-io/proton
A streaming SQL engine, a fast and lightweight alternative to Apache Flink, 🚀 powered by ClickHouse.
Language:C++
Total stars: 596
Stars trend:
#cplusplus
#analytics, #clickhouse, #confluent, #cpp, #flinkalternative, #highperformance, #kakfa, #ksqldbalternative, #redpanda, #simd, #singlebinary, #sql, #streamprocessing, #streamingsql, #udf
A streaming SQL engine, a fast and lightweight alternative to Apache Flink, 🚀 powered by ClickHouse.
Language:C++
Total stars: 596
Stars trend:
30 Jan 2024
10pm ▏ +1
11pm ███▉ +31
31 Jan 2024
12am ███▏ +25
1am ███▏ +25
2am █▋ +13
3am █▌ +12
4am █▏ +9
5am █ +8
6am █▌ +12
7am █ +8
8am █▎ +10#cplusplus
#analytics, #clickhouse, #confluent, #cpp, #flinkalternative, #highperformance, #kakfa, #ksqldbalternative, #redpanda, #simd, #singlebinary, #sql, #streamprocessing, #streamingsql, #udf
vectordotdev/vector
A high-performance observability data pipeline.
Language:Rust
Total stars: 15851
Stars trend:
#rust
#events, #forwarder, #logs, #metrics, #observability, #parser, #pipeline, #router, #rust, #streamprocessing, #vector
A high-performance observability data pipeline.
Language:Rust
Total stars: 15851
Stars trend:
17 Mar 2024
3pm ▏ +1
4pm ▏ +1
5pm +0
6pm +0
7pm ▎ +2
8pm █▎ +10
9pm ██▍ +19
10pm ██▎ +18
11pm ██ +16
18 Mar 2024
12am █▉ +15#rust
#events, #forwarder, #logs, #metrics, #observability, #parser, #pipeline, #router, #rust, #streamprocessing, #vector
pathwaycom/pathway
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Language:Python
Total stars: 2545
Stars trend:
#python
#batchprocessing, #dataanalytics, #datapipelines, #dataprocessing, #dataflow, #etl, #etlframework, #iotanalytics, #kafka, #machinelearningalgorithms, #pathway, #python, #realtime, #rust, #streamprocessing, #streaming, #timeseriesanalysis
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Language:Python
Total stars: 2545
Stars trend:
10 Jun 2024
2am ▏ +1
3am +0
4am ▋ +5
5am █▊ +14
6am ▌ +4
7am ▎ +2
8am +0
9am +0
10am ▎ +2
11am ███▍ +27
12pm █▉ +15
1pm ██ +16#python
#batchprocessing, #dataanalytics, #datapipelines, #dataprocessing, #dataflow, #etl, #etlframework, #iotanalytics, #kafka, #machinelearningalgorithms, #pathway, #python, #realtime, #rust, #streamprocessing, #streaming, #timeseriesanalysis
swimos/swim-rust
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
Language:Rust
Total stars: 156
Stars trend:
#rust
#actormodel, #async, #dataintegration, #decentralizedapplications, #distributedsystems, #framework, #kafka, #realtime, #rust, #serverless, #stateful, #streamprocessing, #streaming, #streamingdatapipelines, #web
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
Language:Rust
Total stars: 156
Stars trend:
28 Jul 2024
3pm █ +8
4pm █ +8
5pm █▎ +10
6pm █▌ +12
7pm █▌ +12
8pm ██▎ +18
9pm █▏ +9
10pm █▎ +10
11pm ▌ +4
29 Jul 2024
12am ▌ +4#rust
#actormodel, #async, #dataintegration, #decentralizedapplications, #distributedsystems, #framework, #kafka, #realtime, #rust, #serverless, #stateful, #streamprocessing, #streaming, #streamingdatapipelines, #web
gazette/core
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Language:Go
Total stars: 622
Stars trend:
#go
#brokers, #eventsourcing, #golang, #streamprocessing, #streamingplatforms
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Language:Go
Total stars: 622
Stars trend:
7 Aug 2024
9pm ▏ +1
10pm ▌ +4
11pm █▊ +14
8 Aug 2024
12am █▏ +9
1am █ +8
2am ▊ +6
3am ▍ +3
4am █▌ +12
5am █▍ +11
6am ▊ +6
7am █▎ +10#go
#brokers, #eventsourcing, #golang, #streamprocessing, #streamingplatforms
infinyon/fluvio
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Language:Rust
Total stars: 3033
Stars trend:
#rust
#cloudnative, #dataflow, #dataintegration, #datapipelines, #distributedsystems, #eventdrivenarchitecture, #realtime, #rust, #serverless, #stateful, #streamprocessing, #streamprocessingengine, #streaming, #streamingdata, #streamingdatapipelines, #streamingdataprocessing, #webassembly
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Language:Rust
Total stars: 3033
Stars trend:
2 Sep 2024
4am ▏ +1
5am ▌ +4
6am ▏ +1
7am ▎ +2
8am +0
9am +0
10am ▏ +1
11am █▎ +10
12pm ▌ +4
1pm ███▎ +26
2pm ██▍ +19
3pm ███▏ +25#rust
#cloudnative, #dataflow, #dataintegration, #datapipelines, #distributedsystems, #eventdrivenarchitecture, #realtime, #rust, #serverless, #stateful, #streamprocessing, #streamprocessingengine, #streaming, #streamingdata, #streamingdatapipelines, #streamingdataprocessing, #webassembly
airtai/faststream
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Language:Python
Total stars: 2800
Stars trend:
#python
#asyncapi, #asyncio, #distributedsystems, #fastkafka, #faststream, #kafka, #nats, #propan, #python, #rabbitmq, #redis, #streamprocessing
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Language:Python
Total stars: 2800
Stars trend:
29 Oct 2024
9am ▍ +3
10am ▏ +1
11am █▎ +10
12pm █ +8
1pm ▉ +7
2pm █▎ +10
3pm █▌ +12
4pm █ +8
5pm █ +8
6pm █▎ +10
7pm █▎ +10
8pm █▋ +13#python
#asyncapi, #asyncio, #distributedsystems, #fastkafka, #faststream, #kafka, #nats, #propan, #python, #rabbitmq, #redis, #streamprocessing
numaproj/numaflow
Kubernetes-native platform to run massively parallel data/streaming jobs
Language:Go
Total stars: 1205
Stars trend:
#go
#dataprocessing, #hacktoberfest, #k8s, #kubernetes, #mapreduce, #pipeline, #streamprocessing
Kubernetes-native platform to run massively parallel data/streaming jobs
Language:Go
Total stars: 1205
Stars trend:
13 Nov 2024
2pm ▎ +2
3pm +0
4pm +0
5pm ████▍ +35
6pm █▋ +13
7pm +0
8pm ▍ +3
9pm +0
10pm ▎ +2
11pm ▎ +2
14 Nov 2024
12am ▌ +4
1am █▊ +14#go
#dataprocessing, #hacktoberfest, #k8s, #kubernetes, #mapreduce, #pipeline, #streamprocessing
fluent/fluent-bit
Fast and Lightweight Logs and Metrics processor for Linux, BSD, OSX and Windows
Language:C
Total stars: 6141
Stars trend:
#c
#c, #cloudnative, #datacollector, #fluentbit, #fluentd, #forwarder, #logging, #logs, #metrics, #opentelemetry, #prometheus, #sqlqueries, #streamprocessing, #traces
Fast and Lightweight Logs and Metrics processor for Linux, BSD, OSX and Windows
Language:C
Total stars: 6141
Stars trend:
28 Dec 2024
7am ▏ +1
8am +0
9am ▎ +2
10am ▎ +2
11am █▌ +12
12pm ▉ +7
1pm █ +8
2pm ██▍ +19
3pm ▍ +3
4pm █ +8
5pm ▉ +7
6pm █▏ +9#c
#c, #cloudnative, #datacollector, #fluentbit, #fluentd, #forwarder, #logging, #logs, #metrics, #opentelemetry, #prometheus, #sqlqueries, #streamprocessing, #traces
pathwaycom/pathway
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Language:Python
Total stars: 12635
Stars trend:
#python
#batchprocessing, #dataanalytics, #datapipelines, #dataprocessing, #dataflow, #etl, #etlframework, #iotanalytics, #kafka, #machinelearningalgorithms, #pathway, #python, #realtime, #rust, #streamprocessing, #streaming, #timeseriesanalysis
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Language:Python
Total stars: 12635
Stars trend:
25 Jan 2025
12am ▏ +1
1am ▎ +2
2am +0
3am +0
4am +0
5am ▏ +1
6am +0
7am █████ +40
8am ████▎ +34#python
#batchprocessing, #dataanalytics, #datapipelines, #dataprocessing, #dataflow, #etl, #etlframework, #iotanalytics, #kafka, #machinelearningalgorithms, #pathway, #python, #realtime, #rust, #streamprocessing, #streaming, #timeseriesanalysis
infinyon/fluvio
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Language:Rust
Total stars: 4721
Stars trend:
#rust
#cloudnative, #dataanalytics, #dataflow, #dataintegration, #datapipelines, #distributedsystems, #eventdrivenarchitecture, #realtime, #rust, #serverless, #stateful, #streamprocessing, #streamprocessingengine, #streaming, #streaminganalytics, #streamingdata, #streamingdatapipelines, #streamingdataprocessing, #webassembly
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Language:Rust
Total stars: 4721
Stars trend:
24 Apr 2025
4pm ▌ +4
5pm ████████▎ +66
6pm █▋ +13
7pm ▎ +2
8pm ▏ +1#rust
#cloudnative, #dataanalytics, #dataflow, #dataintegration, #datapipelines, #distributedsystems, #eventdrivenarchitecture, #realtime, #rust, #serverless, #stateful, #streamprocessing, #streamprocessingengine, #streaming, #streaminganalytics, #streamingdata, #streamingdatapipelines, #streamingdataprocessing, #webassembly
pathwaycom/pathway
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Language:Python
Total stars: 24782
Stars trend:
#python
#batchprocessing, #dataanalytics, #datapipelines, #dataprocessing, #dataflow, #etl, #etlframework, #iotanalytics, #kafka, #machinelearningalgorithms, #pathway, #python, #realtime, #rust, #streamprocessing, #streaming, #timeseriesanalysis
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Language:Python
Total stars: 24782
Stars trend:
17 May 2025
12am ▏ +1
1am +0
2am +0
3am +0
4am +0
5am ▌ +4
6am ▎ +2
7am █▍ +11
8am █████▌ +44
9am ███▋ +29
10am ██▊ +22#python
#batchprocessing, #dataanalytics, #datapipelines, #dataprocessing, #dataflow, #etl, #etlframework, #iotanalytics, #kafka, #machinelearningalgorithms, #pathway, #python, #realtime, #rust, #streamprocessing, #streaming, #timeseriesanalysis