monix/monix-kafka

kafka 1.0 has support for time based offsets.

borissmidt opened this issue · 0 comments

Kafka 1.0 and onward have time based offsets, Currently there is only a boolean which allows you to start from latest or not wen an observable starts.

I propose an extention to also support a starting point from now - a finit time.
And also an offset at a certain time point.