AwesomeRepos
Sign in

Tags / Data pipelines and messaging /

Stream processing

An engine or library that computes results continuously over event streams, such as Flink; not the event log itself.

The 37repositories with this Tag gained +839 net stars in the last 30 days, 11% less than the 30 days before.

0 created in the last 90 days · 11 published a release in the last 30 days · 269K stars in total

All in the Repository Index On Trending

Net stars each day, last 30 days+161 last 7 days

Oct 5, 2026Nov 3, 2026

  • Seed Dataset
  • Rising Admissions

Most net stars, last 30 days

google-ai-edge/mediapipe

Cross-platform, customizable ML solutions for live and streaming media.

+402

48% of the net stars of this Tag

Largest Pace, last 30 days

No other repository gained 2 or more times the net stars of the 30 days before.

Most stars, created in the last 90 days

No other repository with this Tag was created in the last 90 days.

Where the stars went, last 13 weeks

Net stars gained each week. The repositories that gained the most have their own color.

google-ai-edge/mediapipe gained 39% of the net stars of this Tag in the last 13 weeks.

google-ai-edge/mediapipe, week to Aug 11: +112 net starsapache/flink, week to Aug 11: +26 net starspathwaycom/pathway, week to Aug 11: +30 net starsrisingwavelabs/risingwave, week to Aug 11: +29 net starsThreeDotsLabs/watermill, week to Aug 11: +15 net starsAll other repositories, week to Aug 11: +62 net starsgoogle-ai-edge/mediapipe, week to Aug 18: +88 net starsapache/flink, week to Aug 18: +18 net starspathwaycom/pathway, week to Aug 18: +25 net starsrisingwavelabs/risingwave, week to Aug 18: +25 net starsThreeDotsLabs/watermill, week to Aug 18: +7 net starsAll other repositories, week to Aug 18: +74 net starsgoogle-ai-edge/mediapipe, week to Aug 25: +75 net starsapache/flink, week to Aug 25: +29 net starspathwaycom/pathway, week to Aug 25: +37 net starsrisingwavelabs/risingwave, week to Aug 25: +23 net starsThreeDotsLabs/watermill, week to Aug 25: +17 net starsAll other repositories, week to Aug 25: +90 net starsgoogle-ai-edge/mediapipe, week to Sep 1: +89 net starsapache/flink, week to Sep 1: +30 net starspathwaycom/pathway, week to Sep 1: +31 net starsrisingwavelabs/risingwave, week to Sep 1: +11 net starsThreeDotsLabs/watermill, week to Sep 1: +19 net starsAll other repositories, week to Sep 1: +76 net starsgoogle-ai-edge/mediapipe, week to Sep 8: +85 net starsapache/flink, week to Sep 8: +16 net starspathwaycom/pathway, week to Sep 8: +35 net starsrisingwavelabs/risingwave, week to Sep 8: +13 net starsThreeDotsLabs/watermill, week to Sep 8: +11 net starsAll other repositories, week to Sep 8: +56 net starsgoogle-ai-edge/mediapipe, week to Sep 15: +92 net starsapache/flink, week to Sep 15: +21 net starspathwaycom/pathway, week to Sep 15: +32 net starsrisingwavelabs/risingwave, week to Sep 15: +21 net starsThreeDotsLabs/watermill, week to Sep 15: +14 net starsAll other repositories, week to Sep 15: +88 net starsgoogle-ai-edge/mediapipe, week to Sep 22: +87 net starsapache/flink, week to Sep 22: +26 net starspathwaycom/pathway, week to Sep 22: +18 net starsrisingwavelabs/risingwave, week to Sep 22: +15 net starsThreeDotsLabs/watermill, week to Sep 22: +13 net starsAll other repositories, week to Sep 22: +42 net starsgoogle-ai-edge/mediapipe, week to Sep 29: +81 net starsapache/flink, week to Sep 29: +20 net starspathwaycom/pathway, week to Sep 29: +33 net starsrisingwavelabs/risingwave, week to Sep 29: +15 net starsThreeDotsLabs/watermill, week to Sep 29: +5 net starsAll other repositories, week to Sep 29: +80 net starsgoogle-ai-edge/mediapipe, week to Oct 6: +64 net starsapache/flink, week to Oct 6: +15 net starspathwaycom/pathway, week to Oct 6: +16 net starsrisingwavelabs/risingwave, week to Oct 6: +7 net starsThreeDotsLabs/watermill, week to Oct 6: +6 net starsAll other repositories, week to Oct 6: +58 net starsgoogle-ai-edge/mediapipe, week to Oct 13: +103 net starsapache/flink, week to Oct 13: +30 net starspathwaycom/pathway, week to Oct 13: +20 net starsrisingwavelabs/risingwave, week to Oct 13: +10 net starsThreeDotsLabs/watermill, week to Oct 13: +7 net starsAll other repositories, week to Oct 13: +86 net starsgoogle-ai-edge/mediapipe, week to Oct 20: +92 net starsapache/flink, week to Oct 20: +19 net starspathwaycom/pathway, week to Oct 20: +14 net starsrisingwavelabs/risingwave, week to Oct 20: +15 net starsThreeDotsLabs/watermill, week to Oct 20: +13 net starsAll other repositories, week to Oct 20: +65 net starsgoogle-ai-edge/mediapipe, week to Oct 27: +85 net starsapache/flink, week to Oct 27: +21 net starsrisingwavelabs/risingwave, week to Oct 27: +11 net starsThreeDotsLabs/watermill, week to Oct 27: +7 net starsAll other repositories, week to Oct 27: +67 net starsgoogle-ai-edge/mediapipe, week to Nov 3: +108 net starsapache/flink, week to Nov 3: +12 net starsrisingwavelabs/risingwave, week to Nov 3: +7 net starsThreeDotsLabs/watermill, week to Nov 3: +10 net starsAll other repositories, week to Nov 3: +54 net stars

Compare growth

37 repositories with this Tag. Select a column name to change the order.

#RepositoryStarsGained, 30 daysPace
1google-ai-edge/mediapipe

Cross-platform, customizable ML solutions for live and streaming media.

38K+4021.1×
2apache/flink

Apache Flink

26K+86–
3risingwavelabs/risingwave

Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.

9.4K+45–
4ThreeDotsLabs/watermill

Building event-driven applications the easy way in Go.

9.9K+38–
5apache/beam

Apache Beam is a unified programming model for Batch and Streaming data processing.

8.7K+32–
6ag2ai/faststream

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

5.4K+32–
7ArroyoSystems/arroyo

Distributed stream processing engine in Rust

5.1K+32–
8hazelcast/hazelcast

Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.

6.6K+22–
9redpanda-data/connect

Fancy stream processing made operationally mundane

8.8K+21–
10timeplus-io/proton

The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.

2.3K+19–
11MaterializeInc/materialize

The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL

6.4K+18–
12bytewax/bytewax

Python Stream Processing

2.1K+17–
13apache/incubator-kie

Apache KIE (Knowledge Is Everything) is the home of Drools, OptaPlanner, jBPM, and Kogito.

6.3K+10–
14lf-edge/ekuiper

Lightweight data stream processing engine for IoT edge

1.7K+10–
15dotnet/reactive

The Reactive Extensions for .NET

7.2K+8–
16fluvio-community/fluvio

🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.

5.3K+8–
17elixir-broadway/broadway

Concurrent and multi-stage data ingestion and data processing with Elixir

2.7K+8–
18numaproj/numaflow

Kubernetes-native platform to run massively parallel data/streaming jobs

2.8K+7–
19quixio/quix-streams

Python Streaming DataFrames for Kafka

1.6K+7–
20apache/storm

Apache Storm

6.7K+5–

Faster than the 30 days before

Net stars of the last 30 days are 2 or more times those of the 30 days before.

No repository with this Tag meets this rule now.

Slower than the 30 days before

Net stars of the last 30 days are 50% or less of those of the 30 days before.

  1. pathwaycom/pathway-0.2× · -16

New in the last 90 days

Created on GitHub in the last 90 days.

No repository with this Tag meets this rule now.

Older than 2 years, still releasing

Created more than 2 years ago, with a push in the last 7 days and a GitHub release in the last 30 days.

  1. google-ai-edge/mediapipe38K · release today
  2. risingwavelabs/risingwave9.4K · release 23 days ago
  3. redpanda-data/connect8.8K · release 4 days ago
  4. apache/beam8.7K · release 2 days ago
  5. MaterializeInc/materialize6.4K · release 5 days ago
All 11 in the table

Last release more than 180 days ago

The newest GitHub release is more than 180 days old. A repository that never published a release is not in this list.

  1. robinhood/faust6.8K · release 8 years ago
  2. apache/incubator-kie6.3K · release 6 months ago
  3. ArroyoSystems/arroyo5.1K · release 11 months ago
  4. riemann/riemann4.3K · release last year
  5. apache/incubator-heron3.6K · release 4 years ago
All 13 in the table

Top GitHub topics with this Tag

Primary languages

How a repository gets this Tag

An agent reads the description, the GitHub topics, and the start of the README of each repository. It chooses Tags only from the Tag list in the AwesomeRepos source code. For each Tag, it quotes the text. A code check keeps the Tag only when the quote is in that text. The page of each repository shows the quote of each of its Tags. A Tag does not rank repositories. It does not say that one repository can replace another. To report a wrong Tag, use "Report a problem with this page" on the page of the repository.

How the numbers are counted

All numbers come from the Star History of the repositories that have the Tag now. A period is a run of complete UTC days. All numbers on this page count only the repositories that AwesomeRepos shows in lists. A machine computes them each hour.

For each repository, a period counts only when Star History has each of its days, or when the repository was created in the period. Otherwise the table shows "–". The bars of a week with no complete data are grey.

The Pace is the net stars of a period divided by the net stars of the period before. It shows only when Star History covers each day of the period before, with at least 3 net stars a day on average.

The chart at the top adds up the net stars of all the repositories with the Tag. The darker area is the part from the Seed Dataset; the rest is from rising Admissions. A rising Admission comes into the Repository Index because it gained stars quickly. Its Star History before its Admission comes from the Repository Host. Thus the days before many rising Admissions are higher than they were for the repositories in the index at that time. The repositories of the Seed Dataset are a set that does not change.

The releases are the GitHub releases of each repository. The lists and the table do not rank repositories, and they do not say that one repository can replace another.