An incomplete port of Arroyo written in questionable Rust
Very little:
- The streaming abstractions
- In memory broker and consumer for unit tests
- the streaming processor
- A partially implemented Kafka consumer
Look at the two examples in the examples directory