cargo / fv-streams-engine

The FusionVault Streams engine: runs a stream pipeline continuously over Kafka with N independent consumer threads, stateful operators from fv-streams-ops, checkpointed state, exactly-once output, and Kinetics compute steps. Hosted through one small ControlPlane trait.

0.7.0 did not build; the badge stands for .

103 downloads · source · cargo

exactly-once kafka pipeline stream-processing streaming