Welcome to the fifth edition of This Week in Fluvio, our weekly newsletter for development updates to Fluvio open source. Fluvio is a distributed, programmable streaming platform written in Rust.
This week we discovered a bug in the SPU that was causing the request handler
for consumer streams to become blocked, preventing concurrent consumer stream
requests. This happened because upon receiving a stream request with a SmartStream
attached, the main SPU task would start compiling the SmartStream WASM code before
spawning a handler task for it. This meant that the SPU could not accept any
new stream requests until the WASM was finished compiling. In
0.9.5, this has
been fixed by immediately spawning a new task before processing any of the work
for a stream request.
When we originally implemented SmartStreams, we were new to using embedded WASM runtimes, so we hadn’t developed the cleanest patterns and had a fair amount of code duplication. We’ve since gained a lot of experience in best practices for how to structure common patterns for working with WebAssembly modules. This is also largely thanks to the excellent improvements to the wasmtime API since 0.28, which has made it much easier to work with WASM in a multithreaded server environment.
This was a relatively light week for releasing new features, which is partly due to having started some brand-new features that are still in-flight, stay tuned to hear more about those in upcoming weeks.
Until next week!