fluvio
fluvio copied to clipboard
infinyon
Lean and mean distributed stream processing system written in rust and web assembly.
To improve performance of encoding/decoding research: Investigate library such as: - [rkvy](https://github.com/rkyv/rkyv) - ....
No amount of waiting will result in a cluster starting correctly, so I think instead of spinning, we can safely exit and give a useful error to the user. ```...
Your project is intriguing! I was looking through your source, and was wondering if you've considered using [NATS](https://nats.io) as a protocol? NATS is lightweight and has cloud native features that...
Continuing the work of #277, in this issue I'd like to brainstorm ideas on how to make the `FluvioAdmin` API simpler and easier to use. Pieces of functionality should be...
Access fluvio using HTTP protocol. May follow Kafka HTTP Proxy url.
Allow output of logging events to monitoring fluvio using https://docs.rs/tracing-subscriber/latest/tracing_subscriber/.
To support chatbot example that @ajhunyady is working on, we need following capability: - [ ] Incremental partition creation (adding more partition) - [ ] Declarative Partition key mapping Declarative...
For large data sets, there could be many segments. This run generates many segments after a few hours of run: ``` nohup ./target/release/fluvio-test longevity --timeout 90000 -- --runtime-seconds=72000 --producers 300...
`fluvio cluster status` tells state of cluster: * none(discoverable) * stopped (no sc, spu running but data exits) * running (local/k8)
`FORCE_RELEASE` is not having intended effect in `release_docker` job
