这是我的代码：

import boto3

def lambda_handler(event, context):
    cluster_arn = event.get('arn')
    broker_id = event.get('brokerId')

    # Create an MSK client
    msk_client = boto3.client('kafka')

    # Reboot the broker
    response = msk_client.reboot_broker(
        ClusterArn=cluster_arn,
        BrokerIds=[broker_id]
    )

    # Check the response for confirmation
    if response['ResponseMetadata']['HTTPStatusCode'] == 200:
        return "Broker reboot initiated successfully"
    else:
        return "Broker reboot failed"

字符串
这段代码工作正常，我可以观察到我的broker此时正在重新启动。API调用成功代码200表明服务成功接受了API。重新启动本身是重启动的，需要花费任何时间。
至于您遇到的调用超时问题，我想提一下：

1. Boto3 reboot API是MSK级别的API，而不是Kafka级别。
   1.作为#1的结果，您不需要在集群运行的VPC中调用它。它不使用broker，也不使用bootstrap，也不使用Zookeeper来重新启动broker。它是一个服务端点。
   1.不确定它可能与IAM有关，但以防万一，请检查您是否具有执行MSK API所需的所有权限
   重新引导代理的IAM权限：

{
            "Sid": "AllowMskApis",
            "Effect": "Allow",
            "Action": [
                "kafka:ListClusters",
                "kafka:ListClustersV2",
                "kafka:ListNodes",
                "kafka:DescribeCluster",
                "kafka:GetBootstrapBrokers",
                "kafka:RebootBroker"
            ],
            "Resource": [
                "*"
            ]
        }

型