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); 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); } }
Aggregate logs from Apps, sensors, robots, drones, …
Apps and Microservices that communicate in real-time.
Build event-driven Apps on immutable event streams.