fluvio
fluvio copied to clipboard
infinyon
Lean and mean distributed stream processing system written in rust and web assembly.
Currently Topic's resolution is set to `Provisioned`. It doesn't reflect when Partition is online. - Add another resolution to indicate all partition is online - Add another field in the...
Currently client defaults to TLS 1.3 because min protocol is not set. We should set to min of 1.3. TLS v1.3 is faster (less handshake) and more secure: https://docs.rs/native-tls/0.2.7/native_tls/struct.TlsConnectorBuilder.html This...
I was checking what all resource restrictions have been set for WASM code execution. All the tests have been done locally with the latest master `2c0005d` I created a smart...
There should be a way in fluvio client to get the partitions per topic.
Admin object (sc schema), uses enum to represent various objects. It uses string based type encoding. For example, given enum like this ``` Enum AdminList { Spu(SpuSpec), Object2(MyObject) } ```...
I'm hoping this will be as straightforward as adding [`cargo-outdated`](https://github.com/kbknapp/cargo-outdated) to our CI checks. The goal is to ensure our various inter-dependencies for our own `fluvio-*` crates are always using...
Hey, I wasn't really able to find the information in the docs, hope that I didn't just miss it. Is it possible to create a pipeline of SmartModules? Like being...
With [Segment-based time retention](https://github.com/infinyon/fluvio/issues/1944), there is more configuration that needs to be changed. Topic update command should be something like: ``` $ fluvio topic update --retention-time --segment-size ```
Have you a simple way to run fluvio without Kubernetes? My orchestrator is Hashicorp Nomad
The [default Rust client](https://docs.rs/fluvio/0.12.5/fluvio/struct.Fluvio.html#method.connect ) assumes a local cluster, with preference given to the config file at `~/.fluvio/config`. You can also [connect to a different cluster](https://docs.rs/fluvio/0.12.5/fluvio/struct.Fluvio.html#method.connect_with_config) by providing a [`FluvioConfig`](https://docs.rs/fluvio/0.12.5/fluvio/config/struct.FluvioConfig.html)....