View Source aws_kafka (aws v1.0.4)

The operations for managing an Amazon MSK cluster.

Summary

Functions

Associates one or more Scram Secrets with an Amazon MSK cluster.
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
Creates a new MSK cluster.
Creates a new Amazon MSK cluster of either the provisioned or the serverless type.
Creates a new MSK configuration.
Creates a new Kafka Replicator.
Creates a new Amazon MSK VPC connection.
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in your request.

Deletes the specified MSK configuration.

Deletes the Amazon MSK VPC connection specified in your request.
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
Returns a description of the cluster operation specified by the ARN.
Returns a description of the cluster operation specified by the ARN.
Returns a description of the MSK cluster of either the provisioned or the serverless type whose Amazon Resource Name (ARN) is specified in the request.
Returns a description of this MSK configuration.
Returns a description of this revision of the configuration.
Returns a description of the Kafka Replicator whose Amazon Resource Name (ARN) is specified in the request.
Displays information about the specified Amazon MSK VPC connection.
A list of brokers that a client application can use to bootstrap.
Retrieves the contents of the specified MSK cluster policy.
Gets the Apache Kafka versions to which you can update the MSK cluster.
Displays a list of client VPC connections.
Returns a list of all the operations that have been performed on the specified MSK cluster.
Returns a list of all the operations that have been performed on the specified MSK cluster.
Returns a list of all the MSK clusters in the current Region.
Returns a list of all the MSK clusters in the current Region.
Returns a list of all the revisions of an MSK configuration.
Returns a list of all the MSK configurations in this Region.
Returns a list of Apache Kafka versions.
Returns a list of the broker nodes in the cluster.
Lists the replicators.
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
Returns a list of the tags associated with the specified resource.
Displays a list of Amazon MSK VPC connections.

Creates or updates the specified MSK cluster policy.

Executes a reboot on a broker.
Adds tags to the specified MSK resource.
Removes the tags associated with the keys that are provided in the query.

Updates the number of broker nodes in the cluster.

Updates the EBS storage associated with MSK brokers.
Updates all the brokers in the cluster to the specified type.
Updates the cluster with the configuration that is specified in the request body.
Updates the Apache Kafka version for the cluster.

Updates an existing MSK configuration.

Updates the connectivity configuration for the MSK cluster.

Updates the monitoring settings for the cluster.

Updates replication info of a replicator.
You can use this operation to update the encrypting and authentication settings for an existing cluster.
Updates cluster broker volume size (or) sets cluster storage mode to TIERED.

Functions

Link to this function

batch_associate_scram_secret(Client, ClusterArn, Input)

View Source
Associates one or more Scram Secrets with an Amazon MSK cluster.
Link to this function

batch_associate_scram_secret(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

batch_disassociate_scram_secret(Client, ClusterArn, Input)

View Source
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
Link to this function

batch_disassociate_scram_secret(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

create_cluster(Client, Input)

View Source
Creates a new MSK cluster.
Link to this function

create_cluster(Client, Input0, Options0)

View Source
Link to this function

create_cluster_v2(Client, Input)

View Source
Creates a new Amazon MSK cluster of either the provisioned or the serverless type.
Link to this function

create_cluster_v2(Client, Input0, Options0)

View Source
Link to this function

create_configuration(Client, Input)

View Source
Creates a new MSK configuration.
Link to this function

create_configuration(Client, Input0, Options0)

View Source
Link to this function

create_replicator(Client, Input)

View Source
Creates a new Kafka Replicator.
Link to this function

create_replicator(Client, Input0, Options0)

View Source
Link to this function

create_vpc_connection(Client, Input)

View Source
Creates a new Amazon MSK VPC connection.
Link to this function

create_vpc_connection(Client, Input0, Options0)

View Source
Link to this function

delete_cluster(Client, ClusterArn, Input)

View Source
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
Link to this function

delete_cluster(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

delete_cluster_policy(Client, ClusterArn, Input)

View Source
Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in your request.
Link to this function

delete_cluster_policy(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

delete_configuration(Client, Arn, Input)

View Source

Deletes the specified MSK configuration.

The configuration must be in the ACTIVE or DELETE_FAILED state.
Link to this function

delete_configuration(Client, Arn, Input0, Options0)

View Source
Link to this function

delete_replicator(Client, ReplicatorArn, Input)

View Source
Deletes a replicator.
Link to this function

delete_replicator(Client, ReplicatorArn, Input0, Options0)

View Source
Link to this function

delete_vpc_connection(Client, Arn, Input)

View Source
Deletes the Amazon MSK VPC connection specified in your request.
Link to this function

delete_vpc_connection(Client, Arn, Input0, Options0)

View Source
Link to this function

describe_cluster(Client, ClusterArn)

View Source
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
Link to this function

describe_cluster(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

describe_cluster(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_cluster_operation(Client, ClusterOperationArn)

View Source
Returns a description of the cluster operation specified by the ARN.
Link to this function

describe_cluster_operation(Client, ClusterOperationArn, QueryMap, HeadersMap)

View Source
Link to this function

describe_cluster_operation(Client, ClusterOperationArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_cluster_operation_v2(Client, ClusterOperationArn)

View Source
Returns a description of the cluster operation specified by the ARN.
Link to this function

describe_cluster_operation_v2(Client, ClusterOperationArn, QueryMap, HeadersMap)

View Source
Link to this function

describe_cluster_operation_v2(Client, ClusterOperationArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_cluster_v2(Client, ClusterArn)

View Source
Returns a description of the MSK cluster of either the provisioned or the serverless type whose Amazon Resource Name (ARN) is specified in the request.
Link to this function

describe_cluster_v2(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

describe_cluster_v2(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_configuration(Client, Arn)

View Source
Returns a description of this MSK configuration.
Link to this function

describe_configuration(Client, Arn, QueryMap, HeadersMap)

View Source
Link to this function

describe_configuration(Client, Arn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_configuration_revision(Client, Arn, Revision)

View Source
Returns a description of this revision of the configuration.
Link to this function

describe_configuration_revision(Client, Arn, Revision, QueryMap, HeadersMap)

View Source
Link to this function

describe_configuration_revision(Client, Arn, Revision, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_replicator(Client, ReplicatorArn)

View Source
Returns a description of the Kafka Replicator whose Amazon Resource Name (ARN) is specified in the request.
Link to this function

describe_replicator(Client, ReplicatorArn, QueryMap, HeadersMap)

View Source
Link to this function

describe_replicator(Client, ReplicatorArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

describe_vpc_connection(Client, Arn)

View Source
Displays information about the specified Amazon MSK VPC connection.
Link to this function

describe_vpc_connection(Client, Arn, QueryMap, HeadersMap)

View Source
Link to this function

describe_vpc_connection(Client, Arn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

get_bootstrap_brokers(Client, ClusterArn)

View Source
A list of brokers that a client application can use to bootstrap.
Link to this function

get_bootstrap_brokers(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

get_bootstrap_brokers(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

get_cluster_policy(Client, ClusterArn)

View Source
Retrieves the contents of the specified MSK cluster policy.
Link to this function

get_cluster_policy(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

get_cluster_policy(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

get_compatible_kafka_versions(Client)

View Source
Gets the Apache Kafka versions to which you can update the MSK cluster.
Link to this function

get_compatible_kafka_versions(Client, QueryMap, HeadersMap)

View Source
Link to this function

get_compatible_kafka_versions(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_client_vpc_connections(Client, ClusterArn)

View Source
Displays a list of client VPC connections.
Link to this function

list_client_vpc_connections(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

list_client_vpc_connections(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_cluster_operations(Client, ClusterArn)

View Source
Returns a list of all the operations that have been performed on the specified MSK cluster.
Link to this function

list_cluster_operations(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

list_cluster_operations(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_cluster_operations_v2(Client, ClusterArn)

View Source
Returns a list of all the operations that have been performed on the specified MSK cluster.
Link to this function

list_cluster_operations_v2(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

list_cluster_operations_v2(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Returns a list of all the MSK clusters in the current Region.
Link to this function

list_clusters(Client, QueryMap, HeadersMap)

View Source
Link to this function

list_clusters(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_clusters_v2(Client)

View Source
Returns a list of all the MSK clusters in the current Region.
Link to this function

list_clusters_v2(Client, QueryMap, HeadersMap)

View Source
Link to this function

list_clusters_v2(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_configuration_revisions(Client, Arn)

View Source
Returns a list of all the revisions of an MSK configuration.
Link to this function

list_configuration_revisions(Client, Arn, QueryMap, HeadersMap)

View Source
Link to this function

list_configuration_revisions(Client, Arn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_configurations(Client)

View Source
Returns a list of all the MSK configurations in this Region.
Link to this function

list_configurations(Client, QueryMap, HeadersMap)

View Source
Link to this function

list_configurations(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_kafka_versions(Client)

View Source
Returns a list of Apache Kafka versions.
Link to this function

list_kafka_versions(Client, QueryMap, HeadersMap)

View Source
Link to this function

list_kafka_versions(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_nodes(Client, ClusterArn)

View Source
Returns a list of the broker nodes in the cluster.
Link to this function

list_nodes(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

list_nodes(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_replicators(Client)

View Source
Lists the replicators.
Link to this function

list_replicators(Client, QueryMap, HeadersMap)

View Source
Link to this function

list_replicators(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_scram_secrets(Client, ClusterArn)

View Source
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
Link to this function

list_scram_secrets(Client, ClusterArn, QueryMap, HeadersMap)

View Source
Link to this function

list_scram_secrets(Client, ClusterArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_tags_for_resource(Client, ResourceArn)

View Source
Returns a list of the tags associated with the specified resource.
Link to this function

list_tags_for_resource(Client, ResourceArn, QueryMap, HeadersMap)

View Source
Link to this function

list_tags_for_resource(Client, ResourceArn, QueryMap, HeadersMap, Options0)

View Source
Link to this function

list_vpc_connections(Client)

View Source
Displays a list of Amazon MSK VPC connections.
Link to this function

list_vpc_connections(Client, QueryMap, HeadersMap)

View Source
Link to this function

list_vpc_connections(Client, QueryMap, HeadersMap, Options0)

View Source
Link to this function

put_cluster_policy(Client, ClusterArn, Input)

View Source

Creates or updates the specified MSK cluster policy.

If updating the policy, the currentVersion field is required in the request payload.
Link to this function

put_cluster_policy(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

reboot_broker(Client, ClusterArn, Input)

View Source
Executes a reboot on a broker.
Link to this function

reboot_broker(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

reject_client_vpc_connection(Client, ClusterArn, Input)

View Source
Link to this function

reject_client_vpc_connection(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

tag_resource(Client, ResourceArn, Input)

View Source
Adds tags to the specified MSK resource.
Link to this function

tag_resource(Client, ResourceArn, Input0, Options0)

View Source
Link to this function

untag_resource(Client, ResourceArn, Input)

View Source
Removes the tags associated with the keys that are provided in the query.
Link to this function

untag_resource(Client, ResourceArn, Input0, Options0)

View Source
Link to this function

update_broker_count(Client, ClusterArn, Input)

View Source

Updates the number of broker nodes in the cluster.

You can use this operation to increase the number of brokers in an existing cluster. You can't decrease the number of brokers.
Link to this function

update_broker_count(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_broker_storage(Client, ClusterArn, Input)

View Source
Updates the EBS storage associated with MSK brokers.
Link to this function

update_broker_storage(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_broker_type(Client, ClusterArn, Input)

View Source
Updates all the brokers in the cluster to the specified type.
Link to this function

update_broker_type(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_cluster_configuration(Client, ClusterArn, Input)

View Source
Updates the cluster with the configuration that is specified in the request body.
Link to this function

update_cluster_configuration(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_cluster_kafka_version(Client, ClusterArn, Input)

View Source
Updates the Apache Kafka version for the cluster.
Link to this function

update_cluster_kafka_version(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_configuration(Client, Arn, Input)

View Source

Updates an existing MSK configuration.

The configuration must be in the Active state.
Link to this function

update_configuration(Client, Arn, Input0, Options0)

View Source
Link to this function

update_connectivity(Client, ClusterArn, Input)

View Source
Updates the connectivity configuration for the MSK cluster.
Link to this function

update_connectivity(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_monitoring(Client, ClusterArn, Input)

View Source

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.
Link to this function

update_monitoring(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_replication_info(Client, ReplicatorArn, Input)

View Source
Updates replication info of a replicator.
Link to this function

update_replication_info(Client, ReplicatorArn, Input0, Options0)

View Source
Link to this function

update_security(Client, ClusterArn, Input)

View Source
You can use this operation to update the encrypting and authentication settings for an existing cluster.
Link to this function

update_security(Client, ClusterArn, Input0, Options0)

View Source
Link to this function

update_storage(Client, ClusterArn, Input)

View Source
Updates cluster broker volume size (or) sets cluster storage mode to TIERED.
Link to this function

update_storage(Client, ClusterArn, Input0, Options0)

View Source