1.发布时间

KIP Freeze时间：2022年3月2日

Feature Freeze时间：2022年3月16日

Code Freeze时间：2022年3月30日

代码封板后，最少需要保持2周的稳定期。

2.版本需求

Kafka3.2.0对以下19个特性进行了开发。

KIP-815: Support max-timestamp in GetOffsetShell

KIP-814: Static membership protocol should let the leader skip assignment

KIP-811: Add config repartition.purge.interval.ms to Kafka Streams

KIP-810: Allow producing records with null values in Kafka Console Producer

KIP-808: Add support for different unix precisions in TimestampConverter SMT

KIP-806: Add session and window query over kv-store in IQv2

KIP-805: Add range and scan query over kv-store in IQv2

KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

KIP-800: Add reason to JoinGroupRequest and LeaveGroupRequest

KIP-798: Add possibility to write kafka headers in Kafka Console Producer

KIP-796: Interactive Query v2

KIP-791: Add Record Metadata to StateStoreContext

KIP-788: Allow configuring num.network.threads per listener

KIP-784: Add top-level error code field to DescribeLogDirsResponse

KIP-779: Allow Source Tasks to Handle Producer Exceptions

KIP-769: Connect APIs to list all connector plugins and retrieve their configuration definitions

KIP-764: Configurable backlog size for creating Acceptor

KIP-708: Rack awareness for Kafka Streams

KIP-704: Send a hint to the partition leader to recover the partition

KIP-591: Add Kafka Streams config to set default state store

KIP-471: Expose RocksDB Metrics in Kafka Streams (implementation completed)