Add message timestamp to view update context

lovoo / goka

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

BSD 3-Clause "New" or "Revised" License

2.36k stars 173 forks source link

Closed smirzaei closed 5 months ago

smirzaei commented 6 months ago

This PR adds the record timestamp to view's UpdateContext.

Having access to record's timestamp helps us greatly with measuring the lag when the compacted topic is replicated in different regions.

I ran this version locally and it's working well. Please let me know if I missed something. Thank you!