v0.5.1
Requires Kafka 0.10.1+ due to usage of a few new APIs.
- Fix bug when using compression (#458).
- Update the v3 of the Fetch API, allowing a per-request
max_bytes
setting (#468). - Make
#deliver_message
more resilient using retries and backoff. - Add support for SASL SCRAM authentication (#465).
- Refactor and simplify SASL code.
- Fix issue when a consumer resets a partition to its default offset.
- Allow specifying a create time for messages (#481).