更新 Amazon MSK 集群代理的大小 - Amazon Managed Streaming for Apache Kafka
更新 Amazon MSK 集群代理的大小使用更新 Amazon MSK 集群代理的大小 AWS CLI使用更新经纪商规模 API

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

更新 Amazon MSK 集群代理的大小

您可以通过更改代理的大小来按需扩展MSK集群，而无需重新分配 Apache Kafka 分区。通过更改代理的大小，您可以根据工作负载的变化灵活调整MSK集群的计算容量，而不会中断集群 I/O。Amazon 对给定集群中的所有代理MSK使用相同的代理大小。

本节介绍如何更新MSK集群的代理大小。您可以将集群代理大小从 M5 或 T3 更新为 m7g，或者从 m7g 更新为 M5。请注意，迁移到较小的代理规模会降低性能，并降低每个代理可实现的最大吞吐量。迁移到更大的经纪商规模可以提高性能，但成本可能会更高。

当集群启动并运行时，代理规模的更新以滚动方式进行。这意味着 Amaz MSK on 一次关闭一个经纪商来执行经纪商规模更新。有关如何在代理规模更新期间使集群具有高可用性的信息，请参阅。构建高度可用的集群为了进一步减少对生产率的任何潜在影响，您可以在流量较低的时期执行代理规模的更新。

在代理规模更新期间，您可以继续生成和使用数据。但是，必须等到更新完成后才能重启代理或调用 Amazon 操作下列出的任何更新MSK操作。

如果您想将集群更新到较小的代理大小，我们建议您先在测试集群上尝试更新，以了解它会如何影响您的场景。

重要

如果每个代理的分区数超过中指定的最大数量，则无法将集群更新为较小的代理大小 调整集群的大小：每个代理的分区数量。

使用更新 Amazon MSK 集群代理的大小 AWS Management Console

此过程说明如何使用更新 Amazon MSK 集群代理的大小 AWS Management Console

  1. 打开 Amazon MSK 控制台，网址为https://console.aws.amazon.com/msk/。

  2. 选择要为其更新代理大小的MSK集群。

  3. 在集群的详细信息页面上，找到代理摘要部分，然后选择编辑经纪商大小。

  4. 从列表中选择您想要的经纪商规模。

  5. 保存更改。

使用更新 Amazon MSK 集群代理的大小 AWS CLI

运行以下命令，替换 ClusterArn 使用您在创建集群时获得的 Amazon 资源名称 (ARN)。如果您的集群没有，则可以通过列出所有集群来找到它。ARN有关更多信息，请参阅 列出亚马逊MSK集群。

  1. Replace（替换） Current-Cluster-Version 使用集群的当前版本和 TargetType 有了你想要的经纪商的新规模。要了解有关经纪商规模的更多信息，请参阅亚马逊MSK经纪商规模。

    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 使用ARN您在update-broker-type命令输出中获得的。

    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，请参阅UpdateBrokerType。

您可以使用UpdateBrokerType将集群代理大小从 M5 或 T3 更新为 m7g，或者从 m7g 更新为 M5。