robinhood/faust

Health v2 · maintenance only

Flags: no_license

Adoption not part of the score

6825 stars · 543 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-29, confidence not recorded

Faust is a Python stream processing library that ports the ideas of Kafka Streams to Python, using asyncio for high-performance distributed event and stream processing. It provides agents for consuming Kafka topics and durable key/value tables backed by RocksDB for stateful processing.

Use cases

• process billions of kafka events per day in python
• build real-time data pipelines with asyncio
• maintain windowed aggregate counts like clicks per hour
• consume kafka topics and transform streams in plain python
• store distributed state locally with rocksdb tables

When to choose

• you need kafka streams-style processing in python with asyncio
• you want to use pandas, numpy, or other python libraries inside stream processors
• you need durable, windowed state stores for streaming aggregations

When to avoid

• starting a new project - the library is deprecated and unsupported
• you want an actively maintained version - use the faust-streaming fork instead
• you need non-kafka brokers or a DSL-based streaming engine

Facets

library · maturity abandoned

streaming message-queue serialization concurrency microservices big-data python cross-platform kafka-streams asyncio event-processing rocksdb deprecated data-engineering real-time

Member repositories

For agents

markdown · JSON · MCP: product_card(name="robinhood/faust")