log compaction by eventtype


Have you thought about doing something like kafkas log compaction where it's possible to keep the latest message, in the tail of a topic, for each unique message key?


Per stream? Just set maxcount

Max count or max time would define the tail, but instead of deleting the tail, keep latest event for each eventtype.

It’s all about how you lay out you streams you can get this behavior using linkto and writing stream per event type with a projection (linkto) to other streams

Interesting, I'll have to try that out at the keyboard.