Fluvio Streaming

Data streaming platform for connected Apps.

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 Open Source and build your first data streaming App.

Producer

Node
Rust

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?;

Consumer

Node
Rust

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

let consumer = fluvio::consumer("greetings", 0).await?;
let mut stream = consumer.stream(Offset::beginning()).await?;

while let Some(Ok(record)) = stream.next().await {
    if let Some(bytes) = record.try_into_bytes() {
        let string = String::from_utf8_lossy(&bytes);
        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.