1.发布时间

KIP Freeze时间：2018年9月24日

Feature Freeze时间：2018年10月1日

Code Freeze时间：2018年10月15日

Release时间：2018年11月20日

2.版本需求

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

KIP-91 Provide Intuitive User Timeouts in The Producer

KIP-110: Add Codec for ZStandard Compression

KIP-206: Add support for UUID serialization and deserialization

KIP-211: Revise Expiration Semantics of Consumer Group Offsets

KIP-231: Improve the Required ACL of ListGroups API

KIP-235: Add DNS alias support for secured connection

KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses

KIP-306: Configuration for Delaying Response to Failed Client Authentication

KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

KIP-312: Add Overloaded StreamsBuilder Build Method to Accept java.util.Properties

KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier

KIP-321: Update TopologyDescription to better represent Source and Sink Nodes

KIP-322: Return new error code for DeleteTopics API when topic deletion disabled

KIP-324: Add method to get metrics() in AdminClient

KIP-328: Ability to suppress updates for KTables

KIP-330: Add retentionPeriod in SessionBytesStoreSupplier

KIP-332: Update AclCommand to use AdminClient API

KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

KIP-338 Support to exclude the internal topics in kafka-topics.sh command

KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

KIP-342: Add support for Custom SASL extensions in OAuthBearer authentication

KIP-353: Improve Kafka Streams Timestamp Synchronization

KIP-356: Add withCachingDisabled() to StoreBuilder

KIP-357: Add support to list ACLs per principal

KIP-358: Migrate Streams API to Duration instead of long ms times

KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde

KIP-366: Make FunctionConversions deprecated

KIP-372: Naming Repartition Topics for Joins and Grouping