Amazon MSK 增加了对 Apache Kafka 版本 4.1 的支持

发布于: 2025年10月15日

Amazon Managed Streaming for Apache Kafka（Amazon MSK）现在支持 Apache Kafka 版本 4.1，推出了预览版队列功能、一个新的流重平衡协议抢先体验功能以及合格领导者副本（ELR）。除了这些功能之外，Apache Kafka 版本 4.1 还包括各种错误修复和改进。有关更多详细信息，请参阅 Apache Kafka 版本 4.1 发行说明。

Kafka 4.1 的一大亮点是推出了预览版队列功能。客户可以利用多个使用者处理来自同一主题分区的消息，从而提高需要点对点消息传递的工作负载的并行性和吞吐量。新的流重平衡协议是在 Kafka 4.0 的使用者重平衡协议基础上建立的，将代理协调功能扩展到 Kafka Streams，以优化任务分配和实现重新平衡。此外，ELR 现在默认处于启用状态以增强可用性。

要开始在 Amazon MSK 上使用 Apache Kafka 4.1，只需在通过 AWS 管理控制台、AWS CLI 或 AWS SDK 创建新集群时选择版本 4.1.x 即可。您还可以使用就地滚动更新升级现有 MSK 预置集群。Amazon MSK 在升级期间协调代理重启以保持可用性并保护您的数据。目前，所有提供 Amazon MSK 的 AWS 区域均支持 Kafka 版本 4.1。要了解如何开始使用，请参阅 Amazon MSK 开发人员指南。