I’ve just published my tiny library:
It’s an indexed log for events inspired by some Kafka concepts. It models a “stream” as a log and its offset index. It can append, read sequentially from a given offset. Seems to work just fine, however I’d like to improve write throughput. Simple benchmark shows ~8K events at 4 MB/s. Without indexing it’s a few times better.
Profiling kind of shows it’s send/call and I am aware that message passing is costly.
If any of you could see and play with my crap maybe we could improve it together