Kafka2.0.0发布信息


发布于 2018-06-30 / 60 阅读 / 0 评论 /
Kafka2.0.0发布内容和发布时间

Kafka2.0.0发布信息可参考https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=80448820

1.发布时间

KIP Freeze时间:2018年5月22日

Feature Freeze时间:2018年5月29日

Code Freeze时间:2018年6月12日

Release时间:2018年6月26日

2.版本需求

Kafka2.0.0版本对以下40个特性进行了开发。

KIP-86: Configurable SASL callback handlers

KIP-118: Drop Support for Java 7

KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

KIP-176: Remove deprecated new-consumer option for tools

KIP-186: Increase offsets retention default to 7 days

KIP-219 - Improve quota communication

KIP-222 - Add Consumer Group operations to Admin API

KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer

KIP-237: More Controller Health Metrics

KIP-244: Add Record Header support to Kafka Streams Processor API

KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor

KIP-249: Add Delegation Token Operations to KafkaAdminClient

KIP-251: Allow timestamp manipulation in Processor API

KIP-255 OAuth Authentication via SASL/OAUTHBEARER

KIP-257 - Configurable Quota Management

KIP-261: Add Single Value Fetch in Window Stores

KIP-265: Make Windowed Serde to public APIs

KIP-266: Fix consumer indefinite blocking behavior

KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils

KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade

KIP-270 - A Scala Wrapper Library for Kafka Streams

KIP-272: Add API version tag to broker's RequestsPerSec metric

KIP-274: Kafka Streams Skipped Records Metrics

KIP-276 Add StreamsConfig prefix for different consumers

KIP-277 - Fine Grained ACL for CreateTopics API

KIP-278 - Add version option to Kafka's commands

KIP-279: Fix log divergence between leader and follower after fast leader fail over

KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User

KIP-282: Add the listener name to the authentication context

KIP-283: Efficient Memory Usage for Down-Conversion

KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE

KIP-285: Connect Rest Extension Plugin

KIP-290: Support for Prefixed ACLs

KIP-292: Add transformValues() method to KTable

KIP-294 - Enable TLS hostname verification by default

KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization

KIP-297: Externalizing Secrets for Connect Configurations

KIP-298: Error Handling in Connect

KIP-303: Add Dynamic Routing in Streams Sink

KIP-305: Add Connect primitive number converters