为 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. 运行以下命令,将 Cluster 替换为ClusterArn替换为创建集群时所获取的 Amazon 资源名称 (ARN),并将经纪商编号替换为您要重启的代理的 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 重启集群代理,请参阅重新启动代理.