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

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

支持的 Apache Kafka 版本

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

ApacheKafka版本2.5.1

ApacheKafka版本2.5.1包括多个Bug修复和新功能,包括ApacheZookeeper和管理客户端的传输中加密。 Amazon MSK 提供TLSZookeeper端点,您可以使用 DescribeCluster 操作。

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

以下示例显示了 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"

有关使用zookeeper的TLS加密的信息,请参阅 将TLS安全与ApacheZookeeper配合使用.

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

Amazon MSK 错误修复版本2.4.1.1

此版本是 Amazon MSK-仅限ApacheKafka版本2.4.1的Bug-fix版本。此Bug-fix版本包含的修复 KAFKA-9752(卡夫-9752),一个罕见的问题,它会导致消费者群体持续重新平衡并保持 PreparingRebalance 状态。此问题影响运行ApacheKafka版本2.3.1和2.4.1的群集。此版本包含ApacheKafka版本2.5.0中提供的社区生成的修复程序。

注意

Amazon MSK 运行版本2.4.1.1的群集可与任何ApacheKafka客户端兼容,该客户端与ApacheKafka版本2.4.1兼容。

我们建议您使用MSKBug-fix版本2.4.1.1来 Amazon MSK 群集,如果您更喜欢使用ApacheKafka2.4.1。您可以将运行ApacheKafka版本2.4.1的现有群集更新为此版本以纳入此修复。有关升级现有群集的信息,请参阅 更新 Apache Kafka 版本.

要解决此问题而不将群集升级到版本2.4.1.1,请参阅 消费者群体停滞不前 PreparingRebalance 状态 部分 指南。

Apache Kafka 版本 2.4.1

注意

ApacheKafka版本2.4.1已弃用。我们建议您使用版本 Amazon MSK 错误修复版本2.4.1.1 与ApacheKafka2.4.1版兼容的客户端。

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

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

有关如何查找可用区域的信息 IDs,请参阅 亚利桑那州 IDs 您的资源 在 AWS 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 的更多信息,请参阅 Apache Kafka 下载网站上的版本说明