Kafka1.1.0发布信息


发布于 2018-03-31 / 45 阅读 / 0 评论 /
Kafka1.1.0发布内容和发布时间

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