Hi
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?
Thanks
Hi
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?
Thanks
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.