2022年1月24日,Kafka 3.1.0发布。
以下是Kafka 3.1.0版本中解决JIRA问题的摘要,有关该版本的完整文档,入门指南以及关于该项目的信息,请参考Kafka官方文档,或kafka中文教程。
有关升级的注意事项:在升级你的集群之前,请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更,性能变化以及可能影响Kakfa生产的任何其他变化。
Kafka 3.1.0包括许多重要的新功能,以下是一些值得注意的变化的总结:
- Apache Kafka 支持 Java 17
- FetchRequest 支持 Topic IDs (KIP-516)
- 扩展SASL/OAUTHBEARER,支持OIDC(KIP-768)。
- 增加broker数量指标 (KIP-748)
- 区分以毫秒和纳米为单位的一致度量延迟 (KIP-773)
- 急切的再平衡协议已被弃用 (KAFKA-13439)
- 在StreamsException中增加TaskId字段 (KIP-783)
- 外部key连接中的自定义分区器(KIP-775)
- 用SessionStore/WindowStore的开放endpoints进行Fetch/findSessions查询(KIP-766)
- 具有开放endpoints的范围查询(KIP-763)
- 将总阻塞时间指标添加到 Streams (KIP-761)
- 增加额外的配置来控制MirrorMaker2内部主题的命名规则(KIP-690)
有关详细信息,请阅读详细的发行说明。