# fluvio-community/fluvio

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

Repository: https://github.com/fluvio-community/fluvio
Canonical: https://ross.abutalabs.com/products/fluvio
Homepage: https://www.fluvio.io/
Language: Rust
License: Apache-2.0
License Family: permissive
Topics: cloud-native, streaming, rust, real-time, serverless, stateful, stream-processing, webassembly, data-integration, data-flow, distributed-systems, event-driven-architecture, stream-processing-engine, data-pipelines, streaming-data, streaming-data-pipelines, streaming-data-processing, data-analytics, streaming-analytics
Last push: 2026-08-25T11:39:23+00:00

## Health v2 (maintenance only)
Score: 79/100 (v2, computed 2026-09-03T02:20:16.233290+00:00)
- activity 99, release rhythm 40, longevity 100
- inputs: {"age_days": 2560, "days_push": 8, "days_rel": 425, "gap_med": 20.5, "n_releases_24m": 17}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 5247, forks 531 (observed 2026-08-28T04:09:13.641626+00:00)

## What it is
Fluvio is a distributed data streaming engine written in Rust that combines a Kafka-like event streaming platform with the Stateful DataFlow (SDF) framework for stateful stream processing. It supports WASM-based SmartModule transformations, inbound/outbound connectors, and client SDKs for Rust, Python, and JavaScript.

## Use cases
- build real-time data pipelines that transform data in motion
- replace Kafka plus Flink with a single lightweight streaming stack
- collect events from sources like HTTP, MQTT, or Kafka and route them to sinks
- run stateful stream processing with declarative YAML dataflow definitions
- filter and transform streaming records with WASM SmartModules
- stream data between microservices in a cloud-native deployment

## When to choose
- you want a lean, Rust-based alternative to Kafka + Flink with lower infrastructure overhead
- you need real-time transformation and enrichment of event streams
- you want declarative, composable dataflows defined in YAML
- you prefer self-hosting a lightweight streaming platform or using a managed cloud

## When to avoid
- you need the mature ecosystem and broad tooling compatibility of Apache Kafka
- your workloads are batch ETL rather than continuous streaming
- you require Windows natively without WSL2
- you depend on a large community of third-party connectors and clients

## Facets
- artifact type: service
- maturity: active
- function: streaming, message-queue, etl, workflow-automation, cli
- domain: microservices, big-data, analytics, developer-tools
- platform: rust, windows, cloud, self-hosted, cli
- tags: stream-processing, event-streaming, kafka-alternative, wasm-transformations, smartmodules, connectors, data-in-motion, stateful-dataflows, data-engineering, real-time, linux, macos, kubernetes, docker

## Member repositories
- fluvio-community/fluvio (main) score 79

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:09:13.641626+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-29T17:59:34.708563+00:00, confidence not recorded.
  - readme: https://github.com/fluvio-community/fluvio (fetched 2026-08-28T04:09:13.641626+00:00, sha f8188b967e61)
  - homepage: https://www.fluvio.io/ (fetched 2026-08-29T08:54:45.758893+00:00, sha 99a129b515ac)
  - site_page: https://www.fluvio.io/docs/fluvio/quickstart (fetched 2026-08-29T08:54:45.767787+00:00, sha 28d322276e8f)
  - site_page: https://www.fluvio.io/sdf/quickstart (fetched 2026-08-29T08:54:45.769823+00:00, sha b1a3e200da36)
  - site_page: https://www.fluvio.io/docs/cloud/quickstart (fetched 2026-08-29T08:54:45.771448+00:00, sha 1e00a11cadab)
  - site_page: https://www.fluvio.io/docs/connectors/overview (fetched 2026-08-29T08:54:45.773209+00:00, sha 1e29bcda42a9)
  - site_page: https://www.fluvio.io/docs/smartmodules/quickstart (fetched 2026-08-29T08:54:45.774727+00:00, sha 7ce616161c0c)
  - site_page: https://www.fluvio.io/docs/hub/overview (fetched 2026-08-29T08:54:45.776686+00:00, sha c1b7e93b7c69)
  - site_page: https://www.fluvio.io/docs/fluvio/apis/overview (fetched 2026-08-29T08:54:45.779084+00:00, sha fd5656e08a5e)
  - site_page: https://www.fluvio.io/faqs (fetched 2026-08-29T08:54:45.781378+00:00, sha 91fd50ec65f9)
- Data as of 2026-08-30T08:39:29.467469+00:00.