Kafka 4.1.1版本发布说明

原创
半兽人 发表于: 2025-11-27   最后更新时间: 2025-11-27 17:01:14  
{{totalSubscript}} 订阅, 44 游览

以下是Kafka 4.1.1版本中解决的JIRA问题的摘要。有关此版本的完整文档、入门指南和项目信息,请参阅Kafka项目网站。

关于升级的注意事项: 请在升级集群之前仔细阅读此版本的升级文档。升级说明讨论了任何关键信息,包括不兼容性和破坏性变更、性能变化以及可能影响您生产环境中Kafka部署的其他变更。

改进

[KAFKA-19546] - 如果在由静态成员替换触发的组协议降级期间订阅发生变化,则应触发再平衡。
[KAFKA-19747] - 改进对失败的推送遥测请求的处理。

错误修复

[KAFKA-19390] - AbstractIndex#resize() 在Linux上未释放旧的mmap。
[KAFKA-19479] - 当生产者因MESSAGE_TOO_LARGE失败时,Kafka Streams在at_least_once模式下会静默丢弃消息,违反了传递保证。
[KAFKA-19510] - 在多次添加或移除线程时,Kafka Streams并不总是释放锁。
[KAFKA-19668] - processValues() 必须声明为值更改操作。
[KAFKA-19679] - 再次在Kafka Streams迭代器指标中出现NoSuchElementException。
[KAFKA-19690] - 在Kafka Streams (KIP-890) 中意外出现致命错误InvalidTxnStateException。
[KAFKA-19719] - 设置--no-initial-controllers标志时不应验证kraft版本与元数据版本。
[KAFKA-19724] - 全局流线程忽略所有异常。
[KAFKA-19732] - 将KAFKA-19716修复回溯到4.0和4.1版本。
[KAFKA-19748] - 使用范围扫描时内存泄漏。
[KAFKA-19758] - Kafka Connect 4.1类加载的奇怪行为。
[KAFKA-19760] - 当使用offsets.topic.compression.codec时,在组协调器中出现RecordTooLargeExceptions。{- [KAFKA-19775] - 如果在存在正则表达式源KS的情况下创建空主题,则会出错

任务

[KAFKA-15307] - Kafka Streams配置文档已过时

子任务

[KAFKA-19694] - 在Consumer.close()时,StreamsRebalanceListener未被触发}

REF

https://dlcdn.apache.org/kafka/4.1.1/RELEASE_NOTES.html

更新于 2025-11-27

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章