Version 1.12.0 (2017-05-08)
New Features:
- Added support for the
ApiVersions
request and response pair, and Kafka version 0.10.2 (#867). Note that you still need to specify the Kafka version in the Sarama configuration for the time being. - Added a
Brokers
method to the Client which returns the complete set of active brokers (#813). - Added an
InSyncReplicas
method to the Client which returns the set of all in-sync broker IDs for the given partition, now that the Kafka versions for which this was misleading are no longer in our supported set (#872). - Added a
NewCustomHashPartitioner
method which allows constructing a hash partitioner with a custom hash method in case the default (FNV-1a) is not suitable (#837, #841).
Improvements:
- Recognize more Kafka error codes (#859).
Bug Fixes:
- Fix an issue where decoding a malformed FetchRequest would not return the correct error (#818).
- Respect ordering of group protocols in JoinGroupRequests. This fix is transparent if you're using the
AddGroupProtocol
orAddGroupProtocolMetadata
helpers; otherwise you will need to switch from theGroupProtocols
field (now deprecated) to useOrderedGroupProtocols
(#812). - Fix an alignment-related issue with atomics on 32-bit architectures (#859).