This repository has been archived by the owner on Nov 20, 2020. It is now read-only.
0.1.5-rc1
Pre-release
Pre-release
Added Consumer.streamRange to read a specified range of offsets.
Added Consumer.periodicOffsetCommitter which can help ensuring periodic offset commits when using Consumer.stream.
Logging improvements: changed some ERROR messages to WARN, added group coordinator to group related logs, caught missing partition info error
AsyncSeq v2.0.13