A list of brokers that a client application can use to bootstrap. 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.

getClusterPolicy

inline suspend fun KafkaClient.getClusterPolicy(crossinline block: GetClusterPolicyRequest.Builder.() -> Unit): GetClusterPolicyResponse

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

getCompatibleKafkaVersions

inline suspend fun KafkaClient.getCompatibleKafkaVersions(crossinline block: GetCompatibleKafkaVersionsRequest.Builder.() -> Unit): GetCompatibleKafkaVersionsResponse

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

listClientVpcConnections

inline suspend fun KafkaClient.listClientVpcConnections(crossinline block: ListClientVpcConnectionsRequest.Builder.() -> Unit): ListClientVpcConnectionsResponse

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

listClusterOperations

inline suspend fun KafkaClient.listClusterOperations(crossinline block: ListClusterOperationsRequest.Builder.() -> Unit): ListClusterOperationsResponse

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

listClusterOperationsV2

inline suspend fun KafkaClient.listClusterOperationsV2(crossinline block: ListClusterOperationsV2Request.Builder.() -> Unit): ListClusterOperationsV2Response

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

listClusters

inline suspend fun KafkaClient.listClusters(crossinline block: ListClustersRequest.Builder.() -> Unit): ListClustersResponse

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

listClustersV2

inline suspend fun KafkaClient.listClustersV2(crossinline block: ListClustersV2Request.Builder.() -> Unit): ListClustersV2Response

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

listConfigurationRevisions

inline suspend fun KafkaClient.listConfigurationRevisions(crossinline block: ListConfigurationRevisionsRequest.Builder.() -> Unit): ListConfigurationRevisionsResponse

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

listConfigurations

inline suspend fun KafkaClient.listConfigurations(crossinline block: ListConfigurationsRequest.Builder.() -> Unit): ListConfigurationsResponse

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

listKafkaVersions

inline suspend fun KafkaClient.listKafkaVersions(crossinline block: ListKafkaVersionsRequest.Builder.() -> Unit): ListKafkaVersionsResponse

Returns a list of Apache Kafka versions.

listNodes

inline suspend fun KafkaClient.listNodes(crossinline block: ListNodesRequest.Builder.() -> Unit): ListNodesResponse

Returns a list of the broker nodes in the cluster.

listReplicators

inline suspend fun KafkaClient.listReplicators(crossinline block: ListReplicatorsRequest.Builder.() -> Unit): ListReplicatorsResponse

Lists the replicators.

listScramSecrets

inline suspend fun KafkaClient.listScramSecrets(crossinline block: ListScramSecretsRequest.Builder.() -> Unit): ListScramSecretsResponse

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

listTagsForResource

inline suspend fun KafkaClient.listTagsForResource(crossinline block: ListTagsForResourceRequest.Builder.() -> Unit): ListTagsForResourceResponse

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

listVpcConnections

inline suspend fun KafkaClient.listVpcConnections(crossinline block: ListVpcConnectionsRequest.Builder.() -> Unit): ListVpcConnectionsResponse

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

putClusterPolicy

inline suspend fun KafkaClient.putClusterPolicy(crossinline block: PutClusterPolicyRequest.Builder.() -> Unit): PutClusterPolicyResponse

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

rebootBroker

inline suspend fun KafkaClient.rebootBroker(crossinline block: RebootBrokerRequest.Builder.() -> Unit): RebootBrokerResponse

Reboots brokers.

rejectClientVpcConnection

inline suspend fun KafkaClient.rejectClientVpcConnection(crossinline block: RejectClientVpcConnectionRequest.Builder.() -> Unit): RejectClientVpcConnectionResponse

Returns empty response.

tagResource

inline suspend fun KafkaClient.tagResource(crossinline block: TagResourceRequest.Builder.() -> Unit): TagResourceResponse

Adds tags to the specified MSK resource.

untagResource

inline suspend fun KafkaClient.untagResource(crossinline block: UntagResourceRequest.Builder.() -> Unit): UntagResourceResponse

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

updateBrokerCount

inline suspend fun KafkaClient.updateBrokerCount(crossinline block: UpdateBrokerCountRequest.Builder.() -> Unit): UpdateBrokerCountResponse

Updates the number of broker nodes in the cluster.

updateBrokerStorage

inline suspend fun KafkaClient.updateBrokerStorage(crossinline block: UpdateBrokerStorageRequest.Builder.() -> Unit): UpdateBrokerStorageResponse

Updates the EBS storage associated with MSK brokers.

updateBrokerType

inline suspend fun KafkaClient.updateBrokerType(crossinline block: UpdateBrokerTypeRequest.Builder.() -> Unit): UpdateBrokerTypeResponse

Updates EC2 instance type.

updateClusterConfiguration

inline suspend fun KafkaClient.updateClusterConfiguration(crossinline block: UpdateClusterConfigurationRequest.Builder.() -> Unit): UpdateClusterConfigurationResponse

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

updateClusterKafkaVersion

inline suspend fun KafkaClient.updateClusterKafkaVersion(crossinline block: UpdateClusterKafkaVersionRequest.Builder.() -> Unit): UpdateClusterKafkaVersionResponse

Updates the Apache Kafka version for the cluster.

updateConfiguration

inline suspend fun KafkaClient.updateConfiguration(crossinline block: UpdateConfigurationRequest.Builder.() -> Unit): UpdateConfigurationResponse

Updates an MSK configuration.

updateConnectivity

inline suspend fun KafkaClient.updateConnectivity(crossinline block: UpdateConnectivityRequest.Builder.() -> Unit): UpdateConnectivityResponse

Updates the cluster's connectivity configuration.

updateMonitoring

inline suspend fun KafkaClient.updateMonitoring(crossinline block: UpdateMonitoringRequest.Builder.() -> Unit): UpdateMonitoringResponse

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.

updateReplicationInfo

inline suspend fun KafkaClient.updateReplicationInfo(crossinline block: UpdateReplicationInfoRequest.Builder.() -> Unit): UpdateReplicationInfoResponse

Updates replication info of a replicator.

updateSecurity

inline suspend fun KafkaClient.updateSecurity(crossinline block: UpdateSecurityRequest.Builder.() -> Unit): UpdateSecurityResponse

Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.

updateStorage

inline suspend fun KafkaClient.updateStorage(crossinline block: UpdateStorageRequest.Builder.() -> Unit): UpdateStorageResponse

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

withConfig

fun KafkaClient.withConfig(block: KafkaClient.Config.Builder.() -> Unit): KafkaClient

Create a copy of the client with one or more configuration values overridden. This method allows the caller to perform scoped config overrides for one or more client operations.