Kafka3.3.0发布信息可参考https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+3.3.0

1.发布时间

KIP Freeze时间：2022年6月15日

Feature Freeze时间：2022年7月6日

Code Freeze时间：2022年7月20日

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

2.版本需求

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

2.1.KIP-835: 监控KRaft Controller的健康状态

在KRaft模式中，Kafka为集群添加了一个新的Controller Quorum。这些Controller需要能够提交记录标记Kafka是可用的。衡量Kafka可用性的一种方法是定期增加高水印和增加最后提交偏移量。监控服务比起这种被动地可用性测量方法来说，还是更先进的。他们还可以使用这些指标来检查所有broker和controller是否在彼此的偏移范围内。

KIP-859: Add Metadata Log Processing Error Related Metrics

KIP-851: Add requireStable flag into ListConsumerGroupOffsetsOptions

KIP-846: Source/sink node metrics for Consumed/Produced throughput in Streams

KIP-843: Adding addMetricIfAbsent method to Metrics

KIP-841: Fenced replicas should not be allowed to join the ISR in KRaft

KIP-836: Expose replication information of the cluster metadata

KIP-834: Pause / Resume KafkaStreams Topologies

KIP-833: Mark KRaft as Production Ready

KIP-831: Add metric for log recovery progress

KIP-827: Expose log dirs total and usable space via Kafka API

KIP-824: Allowing dumping segmentlogs limiting the batches in the output

KIP-820: Extend KStream process with new Processor API

KIP-812: Introduce another form of the KafkaStreams.close() API that forces the member to leave the consumer group

KIP-794: Strictly Uniform Sticky Partitioner

KIP-778: KRaft to KRaft Upgrades

KIP-709: Extend OffsetFetch requests to accept multiple group ids.

KIP-618: Exactly-Once Support for Source Connectors

KIP-373: Allow users to create delegation tokens for other users