Consumer.stream starvation fix and Consumer.offsets empty array fix

jet / kafunk

Kafunk: F# Kafka client

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

Other

160 stars 63 forks source link

Closed michaelliao5 closed 6 years ago

michaelliao5 commented 6 years ago

Fixed 'Consumer.fetchOffsets' returning no offsets when Array.empty is passed in as partitions per topic
Fixed 'Consumer.stream' function that sometimes causes starvation when AsyncSeq.mergeAll would prioritize first few tasks rather