支持的 Apache Kafka 版本 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

支持的 Apache Kafka 版本

Amazon Managed Streaming for Apache Kafka (Amazon MSK) 支持以下 Apache Kafka 和 Amazon MSK 版本。

Apache Kafka 版本 2.8.0

有关 Apache Kafka 版本 2.8.0 的更多信息,请参阅其发布说明在 Apache Kafka 下载网站上。

Apache Kafka 版本 2.7.1

有关 Apache Kafka 版本 2.7.1 的更多信息,请参阅其发布说明在 Apache Kafka 下载网站上。

Apache Kafka 版本 2.6.2 [推荐]

有关 Apache Kafka 版本 2.6.2 的更多信息,请参阅其发布说明在 Apache Kafka 下载网站上。

Apache Kafka 版本 2.7.0

有关 Apache Kafka 版本 2.7.0 的更多信息,请参阅其发布说明在 Apache Kafka 下载网站上。

Apache Kafka 版本 2.6.1

有关 Apache Kafka 版本 2.6.1 的更多信息,请参阅其发布说明在 Apache Kafka 下载网站上。

Apache Kafka 版本 2.6.0

有关 Apache Kafka 版本 2.6.0 的更多信息,请参阅其发布说明在 Apache Kafka 下载网站上。

Apache Kafka 版本 2.5.1

Apache Kafka 版本 2.5.1 包括一些错误修复和新功能,包括 Apache ZooKeeper 和管理客户端的传输中加密。亚马逊 MSK 提供 TLS ZooKeeper 终端节点,您可以使用DescribeClusteroperation.

的输出DescribeCluster操作包括ZookeeperConnectStringTls节点,其中列出了 TLS zookeeper 终端节点。

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

"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"

有关将 TLS 加密与 zookeeper 一起使用的信息,请参阅。将 TLS 安全性与 Apache ZooKeeper 一起使用.

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

亚马逊 MSK 错误修复版本 2.4.1.1

此版本为 Apache Kafka 版本 2.4.1 的仅限 Amazon MSK 修复版本 2.4.1。此错误修复版本包含的修复程序KAFKA-9752,这是一个罕见的问题,它会导致消费者团体持续重新平衡并保持在PreparingRebalance状态。此问题影响运行 Apache Kafka 版本 2.3.1 和 2.4.1 版的集群。此版本包含社区生产的修复程序,在 Apache Kafka 版本 2.5.0 中可用。

注意

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

如果您更喜欢使用 Apache Kafka 2.4.1,我们建议您对新的亚马逊 MSK 群集使用 MSK 错误修复版本 2.4.1.1。您可以将运行 Apache Kafka 版本 2.4.1 的现有集群更新为此版本,以将此修复程序更新为此版本。有关升级现有集群的信息,请参阅。更新 Apache Kafka 版本.

要在不将集群升级到 2.4.1.1 版本的情况下解决此问题,请参阅消费者组卡在PreparingRebalancestate的 部分指南。

更新为 Apache Kafka 版本 2.4.1(改为使用 2.4.1.1 版)

注意

您不能再使用 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. Amazon 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 的信息,请参阅。您的资源的 AZ ID中的Amazon Resource Access Manager用户指南。

有关设置配置属性的信息,请参阅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 版本 1.1.1(仅适用于现有集群)

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