Version 1.18.0 (2018-09-07)
New Features:
- Make
Partitioner.RequiresConsistency
vary per-message (#1112). - Add customizable partitioner (#1118).
- Add
ClusterAdmin
support forCreateTopic
,DeleteTopic
,CreatePartitions
,DeleteRecords
,DescribeConfig
,AlterConfig
,CreateACL
,ListAcls
,DeleteACL
(#1055).
Improvements:
- Add support for Kafka 2.0.0 (#1149).
- Allow setting
LocalAddr
when dialing an address to support multi-homed hosts (#1123). - Simpler offset management (#1127).
Bug Fixes:
- Fix mutation of
ProducerMessage.MetaData
when producing to Kafka (#1110). - Fix consumer block when response did not contain all the expected topic/partition blocks (#1086).
- Fix consumer block when response contains only constrol messages (#1115).
- Add timeout config for ClusterAdmin requests (#1142).
- Add version check when producing message with headers (#1117).
- Fix
MetadataRequest
for empty list of topics (#1132). - Fix producer topic metadata on-demand fetch when topic error happens in metadata response (#1125).