added consume range feature to consumer

jet / kafunk

Kafunk: F# Kafka client

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

Other

160 stars 63 forks source link

added consume range feature to consumer #164

Closed michaelliao5 closed 7 years ago

michaelliao5 commented 7 years ago

Added consume range feature Consume range Starts consumption from the start offset in the given range Will stop consuming for each partition once it reaches the max boundary offset Will stop and return the messages WITHIN the range if it over consumes