2021年11月15日,Kafka 2.7.2发布。
以下是Kafka 3.1.1版本中解决JIRA问题的摘要,有关该版本的完整文档,入门指南以及关于该项目的信息,请参考Kafka官方文档,或kafka中文教程。
有关升级的注意事项:在升级你的集群之前,请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更,性能变化以及可能影响Kakfa生产的任何其他变化。
改进
[KAFKA-10675] - ConnectSchema.validateValue() 的错误信息应包括模式名称。
[KAFKA-13209] - 升级 jetty-server 以修复 CVE-2021-34429
Bug
[KAFKA-8562] - 尽管有 KAFKA-5051 的支持,但 SASL_SSL 仍会执行反向 DNS 查找
[KAFKA-9831] - 测试失败: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta] - 测试失败。
[KAFKA-9887] - 如果任务在启动过程中失败,则未更新 failed-task-count JMX 指标
[KAFKA-10727] - Kafka 客户端在 Kerberos 重新登录时抛出 AuthenticationException。
[KAFKA-10846] - FileStreamSourceTask 缓冲区可以无限制增长
[KAFKA-12252] - 当 Worker 失去领导力时,分布式放牧者 tick 线程会快速循环
[KAFKA-12262] - 当拥有密钥的跟随者成为领导者时,新的会话密钥永远不会分发
[KAFKA-12667] - 关闭 StateDirectory 时错误日志不正确
[KAFKA-12730] - 从 Java 9 开始,单个 Kerberos 登录失败会导致所有未来连接失败
[KAFKA-12751] - 如果提议的状态与实际状态相同,ISR 仍处于飞行中状态
[KAFKA-12752] - CVE-2021-28168 升级球衣到 2.34 或 3.02
[KAFKA-12904] - Connect 的验证 REST 端点使用不正确的超时
[KAFKA-12948] - 当节点处于连接状态时,NetworkClient.close(node) 会导致 NetworkClient 无法使用
[KAFKA-12951] - 恢复 GlobalKTable 时出现无限循环
[KAFKA-12983] - 在加入群组之前并不总是调用 onJoinPrepare
[KAFKA-12996] - 当获取偏移量小于领导者起始偏移量时,无法正确处理分歧纪元的 OffsetOutOfRange
[KAFKA-13099] - 在过期的事务Ids时出现信息过大错误
[KAFKA-13141] - 如果存在分歧的纪元,领导者不应更新跟随者获取偏移量
[KAFKA-13214] - 消费者不应在断开连接后重置组状态
[KAFKA-13236] - 拓扑测试驱动程序在使用 EOS-beta 配置时崩溃
[KAFKA-13277] - 序列化请求/响应中的长标签字符串时抛出 BufferOverflowException
任务
[KAFKA-12820] - 升级 maven-artifact 依赖项以解决 CVE-2021-26291
[KAFKA-12985] - CVE-2021-28169 - 更新 jetty 到 9.4.42
子任务
[KAFKA-12790] - 移除 SslTransportLayerTest.testUnsupportedTlsVersion