Fluvio Streaming demo

Introduction

Demo that produces and consumes messages using the Fluvio Streaming Engine. The message data is serialized and compressed with bilrost as it performs really well according to this benchmark.

Getting Started

To interact with the Fluvio cluster, install the Fluvio CLI.

Make sure to add $HOME/.fvm/bin and $HOME/.fluvio/bin to your PATH before running these commands:

curl -fsS https://hub.infinyon.cloud/install/install.sh | bash
fvm install
fluvio cluster set --endpoint 127.0.0.1:9003

To create a test topic in Fluvio, run the following command:

fluvio profile add docker 127.0.0.1:9103 docker
fluvio topic create myio --retention-time '7 days' --segment-size '5 Ki' --max-partition-size '30 Ki'
fluvio topic list

Run the solution locally with bacon by executing bacon. Enter 'p' in Bacon to run the producer and enter 'c' to run the consumer. Enter 't' in Bacon to run the test suite with cargo-nextest.