Request adding a consume function readToOffsets

jet / kafunk

Kafunk: F# Kafka client

https://jet.github.io/kafunk/

Other

160 stars 63 forks source link

Request adding a consume function readToOffsets #162

Closed jingle3276 closed 7 years ago

jingle3276 commented 7 years ago

Add a function readToOffsets consumer Map<Partition, Offset>: AsyncSeq<ConsumerState* ConsumerMessageSet> where the returned AsyncSeq knows where to stop based on the input map

eulerfx commented 7 years ago

This has been added as Consumer.streamRange as of 0.1.5