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