Kafka / Client / put_cluster_policy

put_cluster_policy#

Kafka.Client.put_cluster_policy(**kwargs)#

Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.

See also: AWS API Documentation

Request Syntax

response = client.put_cluster_policy(
    ClusterArn='string',
    CurrentVersion='string',
    Policy='string'
)
Parameters:

  • ClusterArn (string) –

    [REQUIRED]

    The Amazon Resource Name (ARN) of the cluster.

  • CurrentVersion (string) – The policy version.

  • Policy (string) –

    [REQUIRED]

    The policy.

Return type:

dict

Returns:

Response Syntax

{
    'CurrentVersion': 'string'
}

Response Structure

  • (dict) –

    Successful response.

    • CurrentVersion (string) –

      The policy version.

Exceptions

  • Kafka.Client.exceptions.BadRequestException

  • Kafka.Client.exceptions.InternalServerErrorException

  • Kafka.Client.exceptions.ForbiddenException