支持的 Apache Kafka 版本 - Amazon Managed Streaming for Apache Kafka
Apache KafkaApache KafkaApache KafkaApache KafkaApache KafkaApache KafkaApache KafkaApache Kafka 2.6.2Apache KafkaApache KafkaApache KafkaApache Kafka 2.0Apache Kafka 2.1亚马逊 MSK 错误修复版本 2.4.1.1Apache KafkaApache Kafka 版本 2.3.1Apache Kafka 版本 2.2.1Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

支持的 Apache Kafka 版本

Amazon Managed Streaming for Apache Kafka。

Apache Kafka

有关 Apache Kafka 版本 3.3.1 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 3.2.0 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 3.1.1 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.8.1 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.8.0 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.7.2 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.7.1 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka 2.6.2

有关 Apache Kafka 版本 2.6.3 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.6.2 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.7.0 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka

有关 Apache Kafka 版本 2.6.1 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka 2.0

有关 Apache Kafka 版本 2.6.0 的信息，请参阅 Apache Kafka 下载网站上的发行说明。

Apache Kafka 2.1

Apache Kafka 版本 2.5.1 包含多个错误修复和新功能，包括 Apache ZooKeeper 和管理客户端的传输中加密。Amazon MSK 提供 TLS ZooKeeper 终端节点，您可以通过DescribeCluster 操作对其进行查询。

该 DescribeCluster操作的输出包括节点，该ZookeeperConnectStringTls节点列出了 TLS zookeeper 端点。

以下示例显示了DescribeCluster操作的响应ZookeeperConnectStringTls节点：

"ZookeeperConnectStringTls": "z-3.awskafkatutorialc.abcd123.c3.kafka.us-east-1.amazonaws.com:2182,z-2.awskafkatutorialc.abcd123.c3.kafka.us-east-1.amazonaws.com:2182,z-1.awskafkatutorialc.abcd123.c3.kafka.us-east-1.amazonaws.com:2182"

有关在 zookeeper 中使用 TLS 加密的信息，请参阅在 Apache 中使用 TLS 安全性 ZooKeeper。

有关 Apache Kafka 版本 2.5.1 的更多信息，请参阅 Apache Kafka 下载网站上的发行说明。

亚马逊 MSK 错误修复版本 2.4.1.1

此版本是 Apache Kafka 版本 2.4.1 的仅限亚马逊 MSK 的错误修复版本。此错误修复版本包含针对 KAFKA-9752 的修复，这是一个罕见的问题，会导致消费者群体不断重新平衡并保持PreparingRebalance状态。此问题会影响运行 2.3.1 此版本包含社区制作的修复程序，该修复程序在 Apache Kafka 版本 2.5.0 中可用。

注意

运行版本 2.4.1.1 的 Amazon MSK 集群与任何与 Apache Kafka 版本 2.4.1 兼容的 Apache Kafka 客户端兼容。

如果您更喜欢使用 Apache Kafka 2.4.1，我们建议您在新的 Amazon MSK 集群中使用 MSK 错误修复版本 2.4.1.1。您可以将运行 Apache Kafka 版本 2.4.1 的现有集群更新到此版本以纳入此修复程序。有关升级现有集群的信息，请参阅更新 Apache Kafka 版本。

要在不将集群升级到版本 2.4.1.1 的情况下解决此问题，请参阅本Amazon MSK 集群故障排除指南的消费者群体陷入困境PreparingRebalancestate部分。

Apache Kafka

注意

您无法再使用 Apache Kafka 版本 2.4.1 创建 MSK 集群。相反，你可以亚马逊 MSK 错误修复版本 2.4.1.1与兼容 Apache Kafka 版本 2.4.1 的客户端一起使用。而且，如果你已经有一个装有 Apache Kafka 版本 2.4.1 的 MSK 集群，我们建议你将其更新为改用 Apache Kafka 版本 2.4.1.1。

KIP-392 是 Apache Kafka 2.4.1 版中包含的重要 Kafka 改进建议之一。此项改进允许使用器从最近的副本提取。要使用此功能，请将使用器属性中的 client.rack 设置为使用器可用区的 ID。可用区 ID 的示例是use1-az1。亚马逊 MSK 设置broker.rack为经纪商可用区的 ID。您还必须将 replica.selector.class 配置属性设置为 org.apache.kafka.common.replica.RackAwareReplicaSelector，这是 Apache Kafka 提供的 rack 感知的一种实现方式。

当您使用此版本的 Apache Kafka 时，PER_TOPIC_PER_BROKER 监控级别中的指标仅在其值首次变为非零后才会显示。有关此问题的更多信息，请参阅 PER_TOPIC_PER_BROKER液位监控。

有关如何查找可用区 ID 的信息，请参阅Amazon Resource Access Manager用户指南中的您的资源的 AZ ID。

有关设置配置属性的信息，请参阅Amazon MSK 配置。

有关 KIP-392 的更多信息，请参阅 Confluence 页面中的允许使用器从最近的副本提取。

有关 Apache Kafka 版本 2.4.1 的更多信息，请参阅 Apache Kafka 下载网站上的版本说明。

Apache Kafka 版本 2.3.1

有关 Apache Kafka 版本 2.3.1 的更多信息，请参阅 Apache Kafka 下载网站上的版本说明。

Apache Kafka 版本 2.2.1

有关 Apache Kafka 版本 2.2.1 的更多信息，请参阅 Apache Kafka 下载网站上的版本说明。

Apache Kafka

您无法再使用 Apache Kafka 版本 1.1.1 创建新的 MSK 集群。您可以继续使用使用 Apache Kafka 版本 1.1.1 配置的现有集群。有关 Apache Kafka 版本 1.1.1 的更多信息，请参阅 Apache Kafka 下载网站上的版本说明。