- Pass consumer state to consume callback (BREAKING)
- Consumer group assignment strategies configurable
- Refine Fetch consumer offsets API
- Current consumer state API
- Fetch consumer offsets API
- Hide internal members
- Documentation
- Log leader-size member assignments
- Fix consumer NotCoordinatorForGroup error recovery
- Refine TCP error recovery
- v0.10.1 support
- Fix overflow bug in Partitioner.roundRobin
- Error flow monitoring
- Fix bug in Async.choose
- Consumer.commitOffsetsToTime
- Consumer doesn't fetch offsets until its starts consuming
- Auto recover producer from error code 2
- Consumer fetch request batching by broker
- Fix protocol codec issue for batched fetch responses
- Periodic offset commit
- Fix a few reconnection/fault tolerance bugs
- Adjust consumer api to allow offset strategies to be parameterized
- A more complete consumer API is now available
- We now use FSharp.Control.AsyncSeq instead of an internal version
- Adjustments have been made to connection recovery and general fault tolerance (still early)
- Improvements to message grouping should improve producer throughput
- initial