更新经纪商类型 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

更新经纪商类型

您可以通过更改经纪商的类型(规模或系列)来根据需要扩展 MSK 集群,而无需重新分配 Apache Kafka 分区。通过更改经纪商的类型,您可以根据工作负载的变化灵活调整 MSK 集群的计算容量,而不会中断集群 I/O。Amazon MSK 对给定集群中的所有经纪商使用相同的代理类型。本节介绍如何更新 MSK 集群的代理类型。在集群启动并运行时,经纪商类型的更新以滚动的方式进行。这意味着亚马逊 MSK 一次取消一个经纪商来执行经纪商类型更新。有关如何在代理类型更新期间使集群高度可用的信息,请参阅构建高度可用的集群. 为了进一步减少对生产力的任何潜在影响,您可以在流量低的时期执行经纪商类型更新。

在代理类型的更新期间,您可以继续生成和消费数据。但是,您必须等到更新完成后才能重启经纪商或调用下列出的任何更新操作Amazon MSK 运营.

如果您想将集群更新为较小的经纪商类型,我们建议您首先在测试群集上尝试更新,以了解它对您的场景的影响。

重要

如果每个代理的分区数超过中指定的最大数量,则无法将集群更新为较小的代理类型 每个代理的分区数.

使用更新经纪商类型Amazon Web Services Management Console

  1. 从打开 Amazon MSK 控制台https://console.amazonaws.cn/msk/.

  2. 选择要更新代理类型的 MSK 集群。

  3. 在集群的详细信息页面上,找到代理摘要部分,然后选择编辑代理类型.

  4. 从列表中选择您想要的代理类型。

  5. 保存更改。

使用更新经纪商类型Amazon CLI

  1. 运行以下命令,并将 ClusterArn 替换为创建集群时所获取的 Amazon 资源名称 (ARN)。如果您没有该集群的 ARN,可以通过列出所有集群来找到它。有关更多信息,请参阅列出 Amazon MSK 集群

    Replace当前群集版本使用集群的当前版本和TargetType使用您希望代理成为的新类型。有关代理类型的更多信息,请参阅代理类型.

    aws kafka update-broker-type --cluster-arn ClusterArn --current-version Current-Cluster-Version --target-instance-type TargetType

    下面的示例说明如何使用此命令:

    aws kafka update-broker-type --cluster-arn "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1" --current-version "K1X5R6FKA87" --target-instance-type kafka.m5.large

    该 命令的输出如以下 JSON 示例所示。

    { "ClusterArn": "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1", "ClusterOperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef" }
  2. 要获取 update-broker-type 操作的结果,请运行以下命令,将 ClusterOperationArn 替换为您在 update-broker-type 命令的输出中获得的 ARN。

    aws kafka describe-cluster-operation --cluster-operation-arn ClusterOperationArn

    describe-cluster-operation 命令的输出如以下 JSON 示例所示。

    { "ClusterOperationInfo": { "ClientRequestId": "982168a3-939f-11e9-8a62-538df00285db", "ClusterArn": "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1", "CreationTime": "2021-01-09T02:24:22.198000+00:00", "OperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef", "OperationState": "UPDATE_COMPLETE", "OperationType": "UPDATE_BROKER_TYPE", "SourceClusterInfo": { "InstanceType": "t3.small" }, "TargetClusterInfo": { "InstanceType": "m5.large" } } }

    如果 OperationState 的值为 UPDATE_IN_PROGRESS,请等待一段时间,然后再次运行 describe-cluster-operation 命令。

使用 API 更新经纪商类型

要使用 API 更新代理类型,请参阅更新经纪人类型.