nats-jetstream
(jetstream | file) --> polars dataframe <--> mariadb (bitemporal)
Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation
implements the RustStream broker contract over async-nats