Fluvio Streaming

Distributed data streaming platform.

Fluvio is a low latency distributed data streaming platform that connects producers and consumers across data silos, tools, and apps.

Sign-up for Fluvio Cloud or install Fluvio locally, choose an API - Rust, Python, Node, Java - and roll out your first real-time data streaming service.

Producer

const fluvio = await Fluvio.connect();
const producer = await fluvio.topicProducer('greetings');
await producer.send("Hello", "World! 🎉");

let producer = fluvio::producer("greetings").await?;
producer.send("Hello", "Fluvio!").await?;

fluvio = Fluvio.connect()
producer = fluvio.topic_producer("greetings")
producer.send("Hello", "World! 🎉"))

package fluvio.java.app;
import com.infinyon.fluvio.Fluvio;
import com.infinyon.fluvio.TopicProducer;

public class App {
    public static void main(String[] args) throws Exception {
        Fluvio fluvio = Fluvio.connect();
        TopicProducer producer = fluvio.topic_producer("hello-java");
        
        producer.send(String.valueOf("1").getBytes(), ("Hello", "Fluvio!").getBytes());
    }
}

Consumer

const fluvio = await Fluvio.connect();
const consumer = await fluvio.partitionConsumer('greetings', 0);
const stream = await consumer.createStream(Offset.FromBeginning());

for await (const record of stream) {
    const key = record.keyString();
    const value = record.valueString();
    console.log(`Consumed record: Key=${key}, value=${value}`);
}

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

while let Some(Ok(record)) = stream.next().await {
    let key_bytes = record.key().unwrap();
    let key = String::from_utf8_lossy(key_bytes).to_string();
    let value = String::from_utf8_lossy(record.value()).to_string();
    println!("Consumed record: Key={:?}, value={}", key, value);
}

from fluvio import (Fluvio, Offset)
consumer = fluvio.partition_consumer("greetings", 0)

for i in consumer.stream(Offset.beginning()):
    key = i.key_string()
    value = i.value_string()
    print("Consumed record: Key=%s, value=%s" % (key, value))

package fluvio.java.app;
import com.infinyon.fluvio.Fluvio;
import com.infinyon.fluvio.PartitionConsumer;
import com.infinyon.fluvio.PartitionConsumerStream;
import com.infinyon.fluvio.Offset;
import com.infinyon.fluvio.Record;

public class App {
    public static void main(String[] args) throws Exception {
        Fluvio fluvio = Fluvio.connect();
        PartitionConsumer consumer = fluvio.partition_consumer("hello-java", 0);

        PartitionConsumerStream stream = consumer.stream(Offset.beginning());
        Record record = stream.next();
        System.out.printf("Consumed record, key=%s, value=%s\n", record.key_string(), record.value_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.