MatejaMaric/kafka-go-cardinality

Handle latancy up to X seconds

Opened this issue · 0 comments

POSSIBLE SOLUTION:
There should be two HyperLogLog-s and two lastFlush-es.
When a message has a timestamp minus interval that's X seconds longer then the it's lastFlush then the result should be emitted.