Kafka3.1.0发布信息可参考https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+3.1.0
1.发布时间
KIP Freeze时间:2021年10月15日
Feature Freeze时间:2021年10月29日
Code Freeze时间:2021年11月12日
代码封板后,最少需要保持2周的稳定期。
2.版本需求
Kafka3.1.0对以下10个特性进行了开发。
KIP-775: Custom partitioners in foreign key joins
KIP-783: Add TaskId field to StreamsException
KIP-773: Differentiate consistently metric latency measured in millis and nanos
KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC
KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore
KIP-763: Range queries with open endpoints
KIP-761: Add Total Blocked Time Metric to Streams
KIP-748: Add Broker Count Metrics
KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention
KIP-633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams