Data streaming platform for connected Apps.
Node Rust

Fluvio is a high performance, low latency data streaming platform for real-time Apps.

Roll out your own log aggregation, DB replication, IOT middle layer, or an event driven infrastructure in a matter of minutes. Use our expressive Node or Rust APIs to create producers/consumers and start rapid experimentation with real-time data.

Sign-up for Fluvio Cloud or download and install Fluvio locally and build your first data streaming App.

const fluvio = await Fluvio.connect();
const producer = await fluvio.topicProducer('greetings');
await producer.sendRecord("Hello, World! 🎉");
let producer = fluvio::producer("greetings").await?;
producer.send_record("Hello, Fluvio!", 0).await?;
const fluvio = await Fluvio.connect();
const consumer = await fluvio.partitionConsumer('greetings', 0);
    index: 0, 
    from: OffsetFrom.Beginning 
}, async (record) => {
    console.log(record) // "Hello, World! 🎉"
let consumer = fluvio::consumer("greetings", 0).await?;
let mut stream =;

while let Some(Ok(record)) = {
    let string = String::from_utf8_lossy(&record.as_ref());
    println!("Got record: {}", string);
Log Aggregation

Aggregate logs from Apps, sensors, robots, drones, …

Collaboration Apps

Apps and Microservices that communicate in real-time.

Event Sourcing

Build event-driven Apps on immutable event streams.