Kafka1.1.0发布信息可参考https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75957546
1.发布时间
KIP Freeze时间:2018年1月23日
Feature Freeze时间:2018年1月30日
Code Freeze时间:2018年2月13日
Release时间:2018年3月28日
2.版本需求
Kafka1.1.0版本对以下26个特性进行了开发。
KIP-86: Configurable SASL callback handlers
KIP-145 - Expose Record Headers in Kafka Connect
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner
KIP-171 - Extend Consumer Group Reset Offset for Stream Application
KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule
KIP-204 : Adding records deletion operation to the new Admin Client API
KIP-205: Add all() and range() API to ReadOnlyWindowStore
KIP-208: Add SSL support to Kafka Connect REST interface
KIP-210 - Provide for custom error handling when Kafka Streams fails to produce
KIP-212: Enforce set of legal characters for connector names
KIP-214: Add zookeeper.max.in.flight.requests config to the broker
KIP-215: Add topic regex support for Connect sinks
KIP-218: Make KafkaFuture.Function java 8 lambda compatible
KIP-220: Add AdminClient into Kafka Streams' ClientSupplier
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer
KIP-224: Add configuration parameter retries
to Streams API
KIP-225 - Use tags for consumer “records.lag” metrics
KIP-226 - Dynamic Broker Configuration
KIP-227 - Introduce Incremental FetchRequests to Increase Partition Scalability
KIP-229: DeleteGroups API
KIP-233: Simplify StreamsBuilder#addGlobalStore
KIP-237: More Controller Health Metrics
KIP-238: Expose Kafka cluster ID in Connect REST API
KIP-239 Add queryableStoreName() to GlobalKTable
KIP-243: Make ProducerConfig and ConsumerConfig constructors public
KIP-247: Add public test utils for Kafka Streams