View Source AWS.Kafka (aws-elixir v1.0.4)

This list doesn't necessarily include all of the brokers in the cluster. The following Python 3.6 example shows how you can use the Amazon Resource Name (ARN) of a cluster to get its bootstrap brokers. If you don't know the ARN of your cluster, you can use the ListClusters operation to get the ARNs of all the clusters in this account and Region.

get_cluster_policy(client, cluster_arn, options \\ [])

Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.

get_compatible_kafka_versions(client, cluster_arn \\ nil, options \\ [])

Gets the Apache Kafka versions to which you can update the MSK cluster.

list_client_vpc_connections(client, cluster_arn, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the VPC connections in this Region.

list_cluster_operations(client, cluster_arn, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the operations that have been performed on the specified MSK cluster.

list_cluster_operations_v2(client, cluster_arn, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the operations that have been performed on the specified MSK cluster.

list_clusters(client, cluster_name_filter \\ nil, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the MSK clusters in the current Region.

list_clusters_v2(client, cluster_name_filter \\ nil, cluster_type_filter \\ nil, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the MSK clusters in the current Region.

list_configuration_revisions(client, arn, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the MSK configurations in this Region.

list_configurations(client, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the MSK configurations in this Region.

list_kafka_versions(client, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of Apache Kafka versions.

list_nodes(client, cluster_arn, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of the broker nodes in the cluster.

list_replicators(client, max_results \\ nil, next_token \\ nil, replicator_name_filter \\ nil, options \\ [])

Lists the replicators.

list_scram_secrets(client, cluster_arn, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of the Scram Secrets associated with an Amazon MSK cluster.

list_tags_for_resource(client, resource_arn, options \\ [])

Returns a list of the tags associated with the specified resource.

list_vpc_connections(client, max_results \\ nil, next_token \\ nil, options \\ [])

Returns a list of all the VPC connections in this Region.

metadata()

put_cluster_policy(client, cluster_arn, input, options \\ [])

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

reboot_broker(client, cluster_arn, input, options \\ [])

Reboots brokers.

reject_client_vpc_connection(client, cluster_arn, input, options \\ [])

Returns empty response.

tag_resource(client, resource_arn, input, options \\ [])

Adds tags to the specified MSK resource.

untag_resource(client, resource_arn, input, options \\ [])

Removes the tags associated with the keys that are provided in the query.

update_broker_count(client, cluster_arn, input, options \\ [])

Updates the number of broker nodes in the cluster.

update_broker_storage(client, cluster_arn, input, options \\ [])

Updates the EBS storage associated with MSK brokers.

update_broker_type(client, cluster_arn, input, options \\ [])

Updates EC2 instance type.

update_cluster_configuration(client, cluster_arn, input, options \\ [])

Updates the cluster with the configuration that is specified in the request body.

update_cluster_kafka_version(client, cluster_arn, input, options \\ [])

Updates the Apache Kafka version for the cluster.

update_configuration(client, arn, input, options \\ [])

Updates an MSK configuration.

update_connectivity(client, cluster_arn, input, options \\ [])

Updates the cluster's connectivity configuration.

update_monitoring(client, cluster_arn, input, options \\ [])

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.

update_replication_info(client, replicator_arn, input, options \\ [])

Updates replication info of a replicator.

update_security(client, cluster_arn, input, options \\ [])

Updates the security settings for the cluster.

You can use this operation to specify encryption and authentication on existing clusters.

update_storage(client, cluster_arn, input, options \\ [])

Updates cluster broker volume size (or) sets cluster storage mode to TIERED.

Settings View Source AWS.Kafka (aws-elixir v1.0.4)

Link to this section Summary

Functions

Link to this section Functions

batch_associate_scram_secret(client, cluster_arn, input, options \\ [])

batch_disassociate_scram_secret(client, cluster_arn, input, options \\ [])

create_cluster(client, input, options \\ [])

create_cluster_v2(client, input, options \\ [])

create_configuration(client, input, options \\ [])

create_replicator(client, input, options \\ [])

create_vpc_connection(client, input, options \\ [])

delete_cluster(client, cluster_arn, input, options \\ [])

delete_cluster_policy(client, cluster_arn, input, options \\ [])

delete_configuration(client, arn, input, options \\ [])

delete_replicator(client, replicator_arn, input, options \\ [])

delete_vpc_connection(client, arn, input, options \\ [])

describe_cluster(client, cluster_arn, options \\ [])

describe_cluster_operation(client, cluster_operation_arn, options \\ [])

describe_cluster_operation_v2(client, cluster_operation_arn, options \\ [])

describe_cluster_v2(client, cluster_arn, options \\ [])

describe_configuration(client, arn, options \\ [])

describe_configuration_revision(client, arn, revision, options \\ [])

describe_replicator(client, replicator_arn, options \\ [])

describe_vpc_connection(client, arn, options \\ [])

get_bootstrap_brokers(client, cluster_arn, options \\ [])