{"files":{"SKILL.md":"---\nname: managed-streaming-for-kafka\ndescription: \"Managed Streaming for Kafka API skill. Use when working with Managed Streaming for Kafka for clusters, api, configurations. Covers 52 endpoints.\"\nversion: 1.0.0\ngenerator: lapsh\n---\n\n# Managed Streaming for Kafka\nAPI version: 2018-11-14\n\n## Auth\nAWS SigV4\n\n## Base URL\nNot specified.\n\n## Setup\n1. Configure auth: AWS SigV4\n2. GET /v1/compatible-kafka-versions -- gets the apache kafka versions to which you can update the msk cluster.\n3. POST /v1/clusters/{clusterArn}/scram-secrets -- create first scram-secret\n\n## Endpoints\n52 endpoints across 10 groups. See references/api-spec.lap for full details.\n\n### Clusters\n| Method | Path | Description |\n|--------|------|-------------|\n| POST | /v1/clusters/{clusterArn}/scram-secrets | Associates one or more Scram Secrets with an Amazon MSK cluster. |\n| POST | /v1/clusters | Creates a new MSK cluster. |\n| DELETE | /v1/clusters/{clusterArn} | Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request. |\n| DELETE | /v1/clusters/{clusterArn}/policy | Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request. |\n| GET | /v1/clusters/{clusterArn} | Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request. |\n| PATCH | /v1/clusters/{clusterArn}/scram-secrets | Disassociates one or more Scram Secrets from an Amazon MSK cluster. |\n| GET | /v1/clusters/{clusterArn}/bootstrap-brokers | A list of brokers that a client application can use to bootstrap. |\n| GET | /v1/clusters/{clusterArn}/policy | Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request. |\n| GET | /v1/clusters/{clusterArn}/operations | Returns a list of all the operations that have been performed on the specified MSK cluster. |\n| GET | /v1/clusters | Returns a list of all the MSK clusters in the current Region. |\n| GET | /v1/clusters/{clusterArn}/nodes | Returns a list of the broker nodes in the cluster. |\n| GET | /v1/clusters/{clusterArn}/scram-secrets | Returns a list of the Scram Secrets associated with an Amazon MSK cluster. |\n| GET | /v1/clusters/{clusterArn}/client-vpc-connections | Returns a list of all the VPC connections in this Region. |\n| PUT | /v1/clusters/{clusterArn}/client-vpc-connection | Returns empty response. |\n| PUT | /v1/clusters/{clusterArn}/policy | Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request. |\n| PUT | /v1/clusters/{clusterArn}/reboot-broker | Reboots brokers. |\n| PUT | /v1/clusters/{clusterArn}/nodes/count | Updates the number of broker nodes in the cluster. |\n| PUT | /v1/clusters/{clusterArn}/nodes/type | Updates EC2 instance type. |\n| PUT | /v1/clusters/{clusterArn}/nodes/storage | Updates the EBS storage associated with MSK brokers. |\n| PUT | /v1/clusters/{clusterArn}/connectivity | Updates the cluster's connectivity configuration. |\n| PUT | /v1/clusters/{clusterArn}/configuration | Updates the cluster with the configuration that is specified in the request body. |\n| PUT | /v1/clusters/{clusterArn}/version | Updates the Apache Kafka version for the cluster. |\n| PUT | /v1/clusters/{clusterArn}/monitoring | Updates the monitoring settings for the cluster. You can use this operation to specify which Apache Kafka metrics you want Amazon MSK to send to Amazon CloudWatch. You can also specify settings for open monitoring with Prometheus. |\n| PATCH | /v1/clusters/{clusterArn}/security | Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters. |\n| PUT | /v1/clusters/{clusterArn}/storage | Updates cluster broker volume size (or) sets cluster storage mode to TIERED. |\n\n### Api\n| Method | Path | Description |\n|--------|------|-------------|\n| POST | /api/v2/clusters | Creates a new MSK cluster. |\n| GET | /api/v2/clusters/{clusterArn} | Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request. |\n| GET | /api/v2/operations/{clusterOperationArn} | Returns a description of the cluster operation specified by the ARN. |\n| GET | /api/v2/clusters/{clusterArn}/operations | Returns a list of all the operations that have been performed on the specified MSK cluster. |\n| GET | /api/v2/clusters | Returns a list of all the MSK clusters in the current Region. |\n\n### Configurations\n| Method | Path | Description |\n|--------|------|-------------|\n| POST | /v1/configurations | Creates a new MSK configuration. |\n| DELETE | /v1/configurations/{arn} | Deletes an MSK Configuration. |\n| GET | /v1/configurations/{arn} | Returns a description of this MSK configuration. |\n| GET | /v1/configurations/{arn}/revisions/{revision} | Returns a description of this revision of the configuration. |\n| GET | /v1/configurations/{arn}/revisions | Returns a list of all the MSK configurations in this Region. |\n| GET | /v1/configurations | Returns a list of all the MSK configurations in this Region. |\n| PUT | /v1/configurations/{arn} | Updates an MSK configuration. |\n\n### Replication\n| Method | Path | Description |\n|--------|------|-------------|\n| POST | /replication/v1/replicators | Creates the replicator. |\n| DELETE | /replication/v1/replicators/{replicatorArn} | Deletes a replicator. |\n| GET | /replication/v1/replicators/{replicatorArn} | Describes a replicator. |\n| GET | /replication/v1/replicators | Lists the replicators. |\n| PUT | /replication/v1/replicators/{replicatorArn}/replication-info | Updates replication info of a replicator. |\n\n### Vpc-connection\n| Method | Path | Description |\n|--------|------|-------------|\n| POST | /v1/vpc-connection | Creates a new MSK VPC connection. |\n| DELETE | /v1/vpc-connection/{arn} | Deletes a MSK VPC connection. |\n| GET | /v1/vpc-connection/{arn} | Returns a description of this MSK VPC connection. |\n\n### Operations\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | /v1/operations/{clusterOperationArn} | Returns a description of the cluster operation specified by the ARN. |\n\n### Compatible-kafka-versions\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | /v1/compatible-kafka-versions | Gets the Apache Kafka versions to which you can update the MSK cluster. |\n\n### Kafka-versions\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | /v1/kafka-versions | Returns a list of Apache Kafka versions. |\n\n### Tags\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | /v1/tags/{resourceArn} | Returns a list of the tags associated with the specified resource. |\n| POST | /v1/tags/{resourceArn} | Adds tags to the specified MSK resource. |\n| DELETE | /v1/tags/{resourceArn} | Removes the tags associated with the keys that are provided in the query. |\n\n### Vpc-connections\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | /v1/vpc-connections | Returns a list of all the VPC connections in this Region. |\n\n## Common Questions\nMatch user requests to endpoints in references/api-spec.lap. Key patterns:\n- \"Create a scram-secret?\" -> POST /v1/clusters/{clusterArn}/scram-secrets\n- \"Create a cluster?\" -> POST /v1/clusters\n- \"Create a configuration?\" -> POST /v1/configurations\n- \"Create a replicator?\" -> POST /replication/v1/replicators\n- \"Create a vpc-connection?\" -> POST /v1/vpc-connection\n- \"Delete a cluster?\" -> DELETE /v1/clusters/{clusterArn}\n- \"Delete a configuration?\" -> DELETE /v1/configurations/{arn}\n- \"Delete a replicator?\" -> DELETE /replication/v1/replicators/{replicatorArn}\n- \"Delete a vpc-connection?\" -> DELETE /v1/vpc-connection/{arn}\n- \"Get cluster details?\" -> GET /v1/clusters/{clusterArn}\n- \"Get operation details?\" -> GET /v1/operations/{clusterOperationArn}\n- \"Get configuration details?\" -> GET /v1/configurations/{arn}\n- \"Get revision details?\" -> GET /v1/configurations/{arn}/revisions/{revision}\n- \"Get replicator details?\" -> GET /replication/v1/replicators/{replicatorArn}\n- \"Get vpc-connection details?\" -> GET /v1/vpc-connection/{arn}\n- \"List all bootstrap-brokers?\" -> GET /v1/clusters/{clusterArn}/bootstrap-brokers\n- \"List all compatible-kafka-versions?\" -> GET /v1/compatible-kafka-versions\n- \"List all policy?\" -> GET /v1/clusters/{clusterArn}/policy\n- \"List all operations?\" -> GET /v1/clusters/{clusterArn}/operations\n- \"List all clusters?\" -> GET /v1/clusters\n- \"List all revisions?\" -> GET /v1/configurations/{arn}/revisions\n- \"List all configurations?\" -> GET /v1/configurations\n- \"List all kafka-versions?\" -> GET /v1/kafka-versions\n- \"List all nodes?\" -> GET /v1/clusters/{clusterArn}/nodes\n- \"List all replicators?\" -> GET /replication/v1/replicators\n- \"List all scram-secrets?\" -> GET /v1/clusters/{clusterArn}/scram-secrets\n- \"Get tag details?\" -> GET /v1/tags/{resourceArn}\n- \"List all client-vpc-connections?\" -> GET /v1/clusters/{clusterArn}/client-vpc-connections\n- \"List all vpc-connections?\" -> GET /v1/vpc-connections\n- \"Delete a tag?\" -> DELETE /v1/tags/{resourceArn}\n- \"Update a configuration?\" -> PUT /v1/configurations/{arn}\n- \"How to authenticate?\" -> See Auth section above\n\n## Response Tips\n- Check response schemas in references/api-spec.lap for field details\n- Create/update endpoints return the modified resource on success\n\n## References\n- Full spec: See references/api-spec.lap for complete endpoint details, parameter tables, and response schemas\n\n> Generated from the official API spec by [LAP](https://lap.sh)\n","references/api-spec.lap":"@lap v0.3\n# Machine-readable API spec. Each @endpoint block is one API call.\n@api Managed Streaming for Kafka\n@version 2018-11-14\n@auth AWS SigV4\n@endpoints 52\n@hint download_for_search\n@toc clusters(25), api(5), configurations(7), replication(5), vpc-connection(3), operations(1), compatible-kafka-versions(1), kafka-versions(1), tags(3), vpc-connections(1)\n\n@group clusters\n@endpoint POST /v1/clusters/{clusterArn}/scram-secrets\n@desc Associates one or more Scram Secrets with an Amazon MSK cluster.\n@required {ClusterArn: str, SecretArnList: [str]}\n@returns(200) {ClusterArn: str?, UnprocessedScramSecrets: [UnprocessedScramSecret]?}\n\n@endpoint POST /v1/clusters\n@desc Creates a new MSK cluster.\n@required {BrokerNodeGroupInfo: BrokerNodeGroupInfo, ClusterName: str, KafkaVersion: str, NumberOfBrokerNodes: int}\n@optional {ClientAuthentication: ClientAuthentication, ConfigurationInfo: ConfigurationInfo, EncryptionInfo: EncryptionInfo, EnhancedMonitoring: str, OpenMonitoring: OpenMonitoringInfo, LoggingInfo: LoggingInfo, Tags: map<str,str>, StorageMode: str}\n@returns(200) {ClusterArn: str?, ClusterName: str?, State: str?}\n\n@endgroup\n\n@group api\n@endpoint POST /api/v2/clusters\n@desc Creates a new MSK cluster.\n@required {ClusterName: str}\n@optional {Tags: map<str,str>, Provisioned: ProvisionedRequest, Serverless: ServerlessRequest}\n@returns(200) {ClusterArn: str?, ClusterName: str?, State: str?, ClusterType: str?}\n\n@endgroup\n\n@group configurations\n@endpoint POST /v1/configurations\n@desc Creates a new MSK configuration.\n@required {Name: str, ServerProperties: bytes}\n@optional {Description: str, KafkaVersions: [str]}\n@returns(200) {Arn: str?, CreationTime: str(timestamp)?, LatestRevision: ConfigurationRevision?{CreationTime: str(timestamp), Description: str?, Revision: int(i64)}, Name: str?, State: str?}\n\n@endgroup\n\n@group replication\n@endpoint POST /replication/v1/replicators\n@desc Creates the replicator.\n@required {KafkaClusters: [KafkaCluster], ReplicationInfoList: [ReplicationInfo], ReplicatorName: str, ServiceExecutionRoleArn: str}\n@optional {Description: str, Tags: map<str,str>}\n@returns(200) {ReplicatorArn: str?, ReplicatorName: str?, ReplicatorState: str?}\n\n@endgroup\n\n@group vpc-connection\n@endpoint POST /v1/vpc-connection\n@desc Creates a new MSK VPC connection.\n@required {TargetClusterArn: str, Authentication: str, VpcId: str, ClientSubnets: [str], SecurityGroups: [str]}\n@optional {Tags: map<str,str>}\n@returns(200) {VpcConnectionArn: str?, State: str?, Authentication: str?, VpcId: str?, ClientSubnets: [str]?, SecurityGroups: [str]?, CreationTime: str(timestamp)?, Tags: map<str,str>?}\n\n@endgroup\n\n@group clusters\n@endpoint DELETE /v1/clusters/{clusterArn}\n@desc Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.\n@required {ClusterArn: str}\n@optional {currentVersion: str}\n@returns(200) {ClusterArn: str?, State: str?}\n\n@endpoint DELETE /v1/clusters/{clusterArn}/policy\n@desc Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.\n@required {ClusterArn: str}\n\n@endgroup\n\n@group configurations\n@endpoint DELETE /v1/configurations/{arn}\n@desc Deletes an MSK Configuration.\n@required {Arn: str}\n@returns(200) {Arn: str?, State: str?}\n\n@endgroup\n\n@group replication\n@endpoint DELETE /replication/v1/replicators/{replicatorArn}\n@desc Deletes a replicator.\n@required {ReplicatorArn: str}\n@optional {currentVersion: str}\n@returns(200) {ReplicatorArn: str?, ReplicatorState: str?}\n\n@endgroup\n\n@group vpc-connection\n@endpoint DELETE /v1/vpc-connection/{arn}\n@desc Deletes a MSK VPC connection.\n@required {Arn: str}\n@returns(200) {VpcConnectionArn: str?, State: str?}\n\n@endgroup\n\n@group clusters\n@endpoint GET /v1/clusters/{clusterArn}\n@desc Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.\n@required {ClusterArn: str}\n@returns(200) {ClusterInfo: ClusterInfo?{ActiveOperationArn: str?, BrokerNodeGroupInfo: BrokerNodeGroupInfo?{BrokerAZDistribution: str?, ClientSubnets: [str], InstanceType: str, SecurityGroups: [str]?, StorageInfo: StorageInfo?{EbsStorageInfo: EBSStorageInfo?}, ConnectivityInfo: ConnectivityInfo?{PublicAccess: PublicAccess?, VpcConnectivity: VpcConnectivity?}, ZoneIds: [str]?}, ClientAuthentication: ClientAuthentication?{Sasl: Sasl?{Scram: Scram?, Iam: Iam?}, Tls: Tls?{CertificateAuthorityArnList: [str]?, Enabled: bool?}, Unauthenticated: Unauthenticated?{Enabled: bool?}}, ClusterArn: str?, ClusterName: str?, CreationTime: str(timestamp)?, CurrentBrokerSoftwareInfo: BrokerSoftwareInfo?{ConfigurationArn: str?, ConfigurationRevision: int(i64)?, KafkaVersion: str?}, CurrentVersion: str?, EncryptionInfo: EncryptionInfo?{EncryptionAtRest: EncryptionAtRest?{DataVolumeKMSKeyId: str}, EncryptionInTransit: EncryptionInTransit?{ClientBroker: str?, InCluster: bool?}}, EnhancedMonitoring: str?, OpenMonitoring: OpenMonitoring?{Prometheus: Prometheus{JmxExporter: JmxExporter?, NodeExporter: NodeExporter?}}, LoggingInfo: LoggingInfo?{BrokerLogs: BrokerLogs{CloudWatchLogs: CloudWatchLogs?, Firehose: Firehose?, S3: S3?}}, NumberOfBrokerNodes: int?, State: str?, StateInfo: StateInfo?{Code: str?, Message: str?}, Tags: map<str, str>?: any, ZookeeperConnectString: str?, ZookeeperConnectStringTls: str?, StorageMode: str?, CustomerActionStatus: str?}}\n\n@endgroup\n\n@group api\n@endpoint GET /api/v2/clusters/{clusterArn}\n@desc Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.\n@required {ClusterArn: str}\n@returns(200) {ClusterInfo: Cluster?{ActiveOperationArn: str?, ClusterType: str?, ClusterArn: str?, ClusterName: str?, CreationTime: str(timestamp)?, CurrentVersion: str?, State: str?, StateInfo: StateInfo?{Code: str?, Message: str?}, Tags: map<str, str>?: any, Provisioned: Provisioned?{BrokerNodeGroupInfo: BrokerNodeGroupInfo{BrokerAZDistribution: str?, ClientSubnets: [str], InstanceType: str, SecurityGroups: [str]?, StorageInfo: StorageInfo?, ConnectivityInfo: ConnectivityInfo?, ZoneIds: [str]?}, CurrentBrokerSoftwareInfo: BrokerSoftwareInfo?{ConfigurationArn: str?, ConfigurationRevision: int(i64)?, KafkaVersion: str?}, ClientAuthentication: ClientAuthentication?{Sasl: Sasl?, Tls: Tls?, Unauthenticated: Unauthenticated?}, EncryptionInfo: EncryptionInfo?{EncryptionAtRest: EncryptionAtRest?, EncryptionInTransit: EncryptionInTransit?}, EnhancedMonitoring: str?, OpenMonitoring: OpenMonitoringInfo?{Prometheus: PrometheusInfo}, LoggingInfo: LoggingInfo?{BrokerLogs: BrokerLogs}, NumberOfBrokerNodes: int, ZookeeperConnectString: str?, ZookeeperConnectStringTls: str?, StorageMode: str?, CustomerActionStatus: str?}, Serverless: Serverless?{VpcConfigs: [VpcConfig], ClientAuthentication: ServerlessClientAuthentication?{Sasl: ServerlessSasl?}}}}\n\n@endgroup\n\n@group operations\n@endpoint GET /v1/operations/{clusterOperationArn}\n@desc Returns a description of the cluster operation specified by the ARN.\n@required {ClusterOperationArn: str}\n@returns(200) {ClusterOperationInfo: ClusterOperationInfo?{ClientRequestId: str?, ClusterArn: str?, CreationTime: str(timestamp)?, EndTime: str(timestamp)?, ErrorInfo: ErrorInfo?{ErrorCode: str?, ErrorString: str?}, OperationArn: str?, OperationState: str?, OperationSteps: [ClusterOperationStep]?, OperationType: str?, SourceClusterInfo: MutableClusterInfo?{BrokerEBSVolumeInfo: [BrokerEBSVolumeInfo]?, ConfigurationInfo: ConfigurationInfo?{Arn: str, Revision: int(i64)}, NumberOfBrokerNodes: int?, EnhancedMonitoring: str?, OpenMonitoring: OpenMonitoring?{Prometheus: Prometheus}, KafkaVersion: str?, LoggingInfo: LoggingInfo?{BrokerLogs: BrokerLogs}, InstanceType: str?, ClientAuthentication: ClientAuthentication?{Sasl: Sasl?, Tls: Tls?, Unauthenticated: Unauthenticated?}, EncryptionInfo: EncryptionInfo?{EncryptionAtRest: EncryptionAtRest?, EncryptionInTransit: EncryptionInTransit?}, ConnectivityInfo: ConnectivityInfo?{PublicAccess: PublicAccess?, VpcConnectivity: VpcConnectivity?}, StorageMode: str?, BrokerCountUpdateInfo: BrokerCountUpdateInfo?{CreatedBrokerIds: [num(f64)]?, DeletedBrokerIds: [num(f64)]?}}, TargetClusterInfo: MutableClusterInfo?{BrokerEBSVolumeInfo: [BrokerEBSVolumeInfo]?, ConfigurationInfo: ConfigurationInfo?{Arn: str, Revision: int(i64)}, NumberOfBrokerNodes: int?, EnhancedMonitoring: str?, OpenMonitoring: OpenMonitoring?{Prometheus: Prometheus}, KafkaVersion: str?, LoggingInfo: LoggingInfo?{BrokerLogs: BrokerLogs}, InstanceType: str?, ClientAuthentication: ClientAuthentication?{Sasl: Sasl?, Tls: Tls?, Unauthenticated: Unauthenticated?}, EncryptionInfo: EncryptionInfo?{EncryptionAtRest: EncryptionAtRest?, EncryptionInTransit: EncryptionInTransit?}, ConnectivityInfo: ConnectivityInfo?{PublicAccess: PublicAccess?, VpcConnectivity: VpcConnectivity?}, StorageMode: str?, BrokerCountUpdateInfo: BrokerCountUpdateInfo?{CreatedBrokerIds: [num(f64)]?, DeletedBrokerIds: [num(f64)]?}}, VpcConnectionInfo: VpcConnectionInfo?{VpcConnectionArn: str?, Owner: str?, UserIdentity: UserIdentity?{Type: str?, PrincipalId: str?}, CreationTime: str(timestamp)?}}}\n\n@endgroup\n\n@group api\n@endpoint GET /api/v2/operations/{clusterOperationArn}\n@desc Returns a description of the cluster operation specified by the ARN.\n@required {ClusterOperationArn: str}\n@returns(200) {ClusterOperationInfo: ClusterOperationV2?{ClusterArn: str?, ClusterType: str?, StartTime: str(timestamp)?, EndTime: str(timestamp)?, ErrorInfo: ErrorInfo?{ErrorCode: str?, ErrorString: str?}, OperationArn: str?, OperationState: str?, OperationType: str?, Provisioned: ClusterOperationV2Provisioned?{OperationSteps: [ClusterOperationStep]?, SourceClusterInfo: MutableClusterInfo?{BrokerEBSVolumeInfo: [BrokerEBSVolumeInfo]?, ConfigurationInfo: ConfigurationInfo?, NumberOfBrokerNodes: int?, EnhancedMonitoring: str?, OpenMonitoring: OpenMonitoring?, KafkaVersion: str?, LoggingInfo: LoggingInfo?, InstanceType: str?, ClientAuthentication: ClientAuthentication?, EncryptionInfo: EncryptionInfo?, ConnectivityInfo: ConnectivityInfo?, StorageMode: str?, BrokerCountUpdateInfo: BrokerCountUpdateInfo?}, TargetClusterInfo: MutableClusterInfo?{BrokerEBSVolumeInfo: [BrokerEBSVolumeInfo]?, ConfigurationInfo: ConfigurationInfo?, NumberOfBrokerNodes: int?, EnhancedMonitoring: str?, OpenMonitoring: OpenMonitoring?, KafkaVersion: str?, LoggingInfo: LoggingInfo?, InstanceType: str?, ClientAuthentication: ClientAuthentication?, EncryptionInfo: EncryptionInfo?, ConnectivityInfo: ConnectivityInfo?, StorageMode: str?, BrokerCountUpdateInfo: BrokerCountUpdateInfo?}, VpcConnectionInfo: VpcConnectionInfo?{VpcConnectionArn: str?, Owner: str?, UserIdentity: UserIdentity?, CreationTime: str(timestamp)?}}, Serverless: ClusterOperationV2Serverless?{VpcConnectionInfo: VpcConnectionInfoServerless?{CreationTime: str(timestamp)?, Owner: str?, UserIdentity: UserIdentity?, VpcConnectionArn: str?}}}}\n\n@endgroup\n\n@group configurations\n@endpoint GET /v1/configurations/{arn}\n@desc Returns a description of this MSK configuration.\n@required {Arn: str}\n@returns(200) {Arn: str?, CreationTime: str(timestamp)?, Description: str?, KafkaVersions: [str]?, LatestRevision: ConfigurationRevision?{CreationTime: str(timestamp), Description: str?, Revision: int(i64)}, Name: str?, State: str?}\n\n@endpoint GET /v1/configurations/{arn}/revisions/{revision}\n@desc Returns a description of this revision of the configuration.\n@required {Arn: str, Revision: int(i64)}\n@returns(200) {Arn: str?, CreationTime: str(timestamp)?, Description: str?, Revision: int(i64)?, ServerProperties: bytes?}\n\n@endgroup\n\n@group replication\n@endpoint GET /replication/v1/replicators/{replicatorArn}\n@desc Describes a replicator.\n@required {ReplicatorArn: str}\n@returns(200) {CreationTime: str(timestamp)?, CurrentVersion: str?, IsReplicatorReference: bool?, KafkaClusters: [KafkaClusterDescription]?, ReplicationInfoList: [ReplicationInfoDescription]?, ReplicatorArn: str?, ReplicatorDescription: str?, ReplicatorName: str?, ReplicatorResourceArn: str?, ReplicatorState: str?, ServiceExecutionRoleArn: str?, StateInfo: ReplicationStateInfo?{Code: str?, Message: str?}, Tags: map<str,str>?}\n\n@endgroup\n\n@group vpc-connection\n@endpoint GET /v1/vpc-connection/{arn}\n@desc Returns a description of this MSK VPC connection.\n@required {Arn: str}\n@returns(200) {VpcConnectionArn: str?, TargetClusterArn: str?, State: str?, Authentication: str?, VpcId: str?, Subnets: [str]?, SecurityGroups: [str]?, CreationTime: str(timestamp)?, Tags: map<str,str>?}\n\n@endgroup\n\n@group clusters\n@endpoint PATCH /v1/clusters/{clusterArn}/scram-secrets\n@desc Disassociates one or more Scram Secrets from an Amazon MSK cluster.\n@required {ClusterArn: str, SecretArnList: [str]}\n@returns(200) {ClusterArn: str?, UnprocessedScramSecrets: [UnprocessedScramSecret]?}\n\n@endpoint GET /v1/clusters/{clusterArn}/bootstrap-brokers\n@desc A list of brokers that a client application can use to bootstrap.\n@required {ClusterArn: str}\n@returns(200) {BootstrapBrokerString: str?, BootstrapBrokerStringTls: str?, BootstrapBrokerStringSaslScram: str?, BootstrapBrokerStringSaslIam: str?, BootstrapBrokerStringPublicTls: str?, BootstrapBrokerStringPublicSaslScram: str?, BootstrapBrokerStringPublicSaslIam: str?, BootstrapBrokerStringVpcConnectivityTls: str?, BootstrapBrokerStringVpcConnectivitySaslScram: str?, BootstrapBrokerStringVpcConnectivitySaslIam: str?}\n\n@endgroup\n\n@group compatible-kafka-versions\n@endpoint GET /v1/compatible-kafka-versions\n@desc Gets the Apache Kafka versions to which you can update the MSK cluster.\n@optional {clusterArn: str}\n@returns(200) {CompatibleKafkaVersions: [CompatibleKafkaVersion]?}\n\n@endgroup\n\n@group clusters\n@endpoint GET /v1/clusters/{clusterArn}/policy\n@desc Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.\n@required {ClusterArn: str}\n@returns(200) {CurrentVersion: str?, Policy: str?}\n\n@endpoint GET /v1/clusters/{clusterArn}/operations\n@desc Returns a list of all the operations that have been performed on the specified MSK cluster.\n@required {ClusterArn: str}\n@optional {maxResults: int, nextToken: str}\n@returns(200) {ClusterOperationInfoList: [ClusterOperationInfo]?, NextToken: str?}\n\n@endgroup\n\n@group api\n@endpoint GET /api/v2/clusters/{clusterArn}/operations\n@desc Returns a list of all the operations that have been performed on the specified MSK cluster.\n@required {ClusterArn: str}\n@optional {maxResults: int, nextToken: str}\n@returns(200) {ClusterOperationInfoList: [ClusterOperationV2Summary]?, NextToken: str?}\n\n@endgroup\n\n@group clusters\n@endpoint GET /v1/clusters\n@desc Returns a list of all the MSK clusters in the current Region.\n@optional {clusterNameFilter: str, maxResults: int, nextToken: str}\n@returns(200) {ClusterInfoList: [ClusterInfo]?, NextToken: str?}\n\n@endgroup\n\n@group api\n@endpoint GET /api/v2/clusters\n@desc Returns a list of all the MSK clusters in the current Region.\n@optional {clusterNameFilter: str, clusterTypeFilter: str, maxResults: int, nextToken: str}\n@returns(200) {ClusterInfoList: [Cluster]?, NextToken: str?}\n\n@endgroup\n\n@group configurations\n@endpoint GET /v1/configurations/{arn}/revisions\n@desc Returns a list of all the MSK configurations in this Region.\n@required {Arn: str}\n@optional {maxResults: int, nextToken: str}\n@returns(200) {NextToken: str?, Revisions: [ConfigurationRevision]?}\n\n@endpoint GET /v1/configurations\n@desc Returns a list of all the MSK configurations in this Region.\n@optional {maxResults: int, nextToken: str}\n@returns(200) {Configurations: [Configuration]?, NextToken: str?}\n\n@endgroup\n\n@group kafka-versions\n@endpoint GET /v1/kafka-versions\n@desc Returns a list of Apache Kafka versions.\n@optional {maxResults: int, nextToken: str}\n@returns(200) {KafkaVersions: [KafkaVersion]?, NextToken: str?}\n\n@endgroup\n\n@group clusters\n@endpoint GET /v1/clusters/{clusterArn}/nodes\n@desc Returns a list of the broker nodes in the cluster.\n@required {ClusterArn: str}\n@optional {maxResults: int, nextToken: str}\n@returns(200) {NextToken: str?, NodeInfoList: [NodeInfo]?}\n\n@endgroup\n\n@group replication\n@endpoint GET /replication/v1/replicators\n@desc Lists the replicators.\n@optional {maxResults: int, nextToken: str, replicatorNameFilter: str}\n@returns(200) {NextToken: str?, Replicators: [ReplicatorSummary]?}\n\n@endgroup\n\n@group clusters\n@endpoint GET /v1/clusters/{clusterArn}/scram-secrets\n@desc Returns a list of the Scram Secrets associated with an Amazon MSK cluster.\n@required {ClusterArn: str}\n@optional {maxResults: int, nextToken: str}\n@returns(200) {NextToken: str?, SecretArnList: [str]?}\n\n@endgroup\n\n@group tags\n@endpoint GET /v1/tags/{resourceArn}\n@desc Returns a list of the tags associated with the specified resource.\n@required {ResourceArn: str}\n@returns(200) {Tags: map<str,str>?}\n\n@endgroup\n\n@group clusters\n@endpoint GET /v1/clusters/{clusterArn}/client-vpc-connections\n@desc Returns a list of all the VPC connections in this Region.\n@required {ClusterArn: str}\n@optional {maxResults: int, nextToken: str}\n@returns(200) {ClientVpcConnections: [ClientVpcConnection]?, NextToken: str?}\n\n@endgroup\n\n@group vpc-connections\n@endpoint GET /v1/vpc-connections\n@desc Returns a list of all the VPC connections in this Region.\n@optional {maxResults: int, nextToken: str}\n@returns(200) {VpcConnections: [VpcConnection]?, NextToken: str?}\n\n@endgroup\n\n@group clusters\n@endpoint PUT /v1/clusters/{clusterArn}/client-vpc-connection\n@desc Returns empty response.\n@required {ClusterArn: str, VpcConnectionArn: str}\n\n@endpoint PUT /v1/clusters/{clusterArn}/policy\n@desc Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.\n@required {ClusterArn: str, Policy: str}\n@optional {CurrentVersion: str}\n@returns(200) {CurrentVersion: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/reboot-broker\n@desc Reboots brokers.\n@required {ClusterArn: str, BrokerIds: [str]}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endgroup\n\n@group tags\n@endpoint POST /v1/tags/{resourceArn}\n@desc Adds tags to the specified MSK resource.\n@required {ResourceArn: str, Tags: map<str,str>}\n\n@endpoint DELETE /v1/tags/{resourceArn}\n@desc Removes the tags associated with the keys that are provided in the query.\n@required {ResourceArn: str, tagKeys: [str]}\n\n@endgroup\n\n@group clusters\n@endpoint PUT /v1/clusters/{clusterArn}/nodes/count\n@desc Updates the number of broker nodes in the cluster.\n@required {ClusterArn: str, CurrentVersion: str, TargetNumberOfBrokerNodes: int}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/nodes/type\n@desc Updates EC2 instance type.\n@required {ClusterArn: str, CurrentVersion: str, TargetInstanceType: str}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/nodes/storage\n@desc Updates the EBS storage associated with MSK brokers.\n@required {ClusterArn: str, CurrentVersion: str, TargetBrokerEBSVolumeInfo: [BrokerEBSVolumeInfo]}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endgroup\n\n@group configurations\n@endpoint PUT /v1/configurations/{arn}\n@desc Updates an MSK configuration.\n@required {Arn: str, ServerProperties: bytes}\n@optional {Description: str}\n@returns(200) {Arn: str?, LatestRevision: ConfigurationRevision?{CreationTime: str(timestamp), Description: str?, Revision: int(i64)}}\n\n@endgroup\n\n@group clusters\n@endpoint PUT /v1/clusters/{clusterArn}/connectivity\n@desc Updates the cluster's connectivity configuration.\n@required {ClusterArn: str, ConnectivityInfo: ConnectivityInfo, CurrentVersion: str}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/configuration\n@desc Updates the cluster with the configuration that is specified in the request body.\n@required {ClusterArn: str, ConfigurationInfo: ConfigurationInfo, CurrentVersion: str}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/version\n@desc Updates the Apache Kafka version for the cluster.\n@required {ClusterArn: str, CurrentVersion: str, TargetKafkaVersion: str}\n@optional {ConfigurationInfo: ConfigurationInfo}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/monitoring\n@desc Updates the monitoring settings for the cluster. You can use this operation to specify which Apache Kafka metrics you want Amazon MSK to send to Amazon CloudWatch. You can also specify settings for open monitoring with Prometheus.\n@required {ClusterArn: str, CurrentVersion: str}\n@optional {EnhancedMonitoring: str, OpenMonitoring: OpenMonitoringInfo, LoggingInfo: LoggingInfo}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endgroup\n\n@group replication\n@endpoint PUT /replication/v1/replicators/{replicatorArn}/replication-info\n@desc Updates replication info of a replicator.\n@required {ReplicatorArn: str, CurrentVersion: str, SourceKafkaClusterArn: str, TargetKafkaClusterArn: str}\n@optional {ConsumerGroupReplication: ConsumerGroupReplicationUpdate, TopicReplication: TopicReplicationUpdate}\n@returns(200) {ReplicatorArn: str?, ReplicatorState: str?}\n\n@endgroup\n\n@group clusters\n@endpoint PATCH /v1/clusters/{clusterArn}/security\n@desc Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.\n@required {ClusterArn: str, CurrentVersion: str}\n@optional {ClientAuthentication: ClientAuthentication, EncryptionInfo: EncryptionInfo}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endpoint PUT /v1/clusters/{clusterArn}/storage\n@desc Updates cluster broker volume size (or) sets cluster storage mode to TIERED.\n@required {ClusterArn: str, CurrentVersion: str}\n@optional {ProvisionedThroughput: ProvisionedThroughput, StorageMode: str, VolumeSizeGB: int}\n@returns(200) {ClusterArn: str?, ClusterOperationArn: str?}\n\n@endgroup\n\n@end\n"}}