重启代理以获取 Amazon MSK 集群 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

重启代理以获取 Amazon MSK 集群

当您想为 MSK 集群重新启动经纪商时,请使用此 Amazon MSK 操作。要重启集的代理,请确保集群ACTIVE状态。

Amazon MSK 服务可能会在系统维护(例如修补或版本升级)期间为 MSK 集群重新启动代理商。手动重启经纪人可以让你测试 Kafka 客户端的弹性,以确定他们如何应对系统维护。

使用Amazon Web Services Management Console

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

  2. 选择要重启代理的 MSK 集群。

  3. 向下滚动到代理详情部分,然后选择要重启的代理。

  4. 选择重启代理按钮。

使用Amazon CLI

  1. 运行以下命令,替换以下命令ClusterArn使用您在创建集群时获取的 Amazon 资源名称 (ARN),以及Broker ID使用您要重启的代理的 ID。

    注意

    这些区域有:reboot-broker操作一次只支持重启一个代理。

    如果您没有该集群的 ARN,可以通过列出所有集群来找到它。有关更多信息,请参阅 列出 Amazon MSK 集群

    如果您没有集群的代理 ID,可以通过列出代理节点来找到它们。有关更多信息,请参阅 。列表节点.

    aws kafka reboot-broker --cluster-arn ClusterArn --broker-ids BrokerId

    reboot-broker 操作的输出如以下 JSON 所示:

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

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

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

    { "ClusterOperationInfo": { "ClientRequestId": "c0b7af47-8591-45b5-9c0c-909a1a2c99ea", "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2", "CreationTime": "2019-09-25T23:48:04.794Z", "OperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef", "OperationState": "REBOOT_IN_PROGRESS", "OperationType": "REBOOT_NODE", "SourceClusterInfo": {}, "TargetClusterInfo": {} } }

重启操作完成后,OperationStateREBOOT_COMPLETE.

使用 API 重启代理

要使用 API 重启集群中的代理,请参阅RebootBroker.