Struct aws_sdk_kafka::Client

pub struct Client { /* private fields */ }

Client for Managed Streaming for Kafka

Client for invoking operations on Managed Streaming for Kafka. Each operation on Managed Streaming for Kafka is a method on this this struct. .send() MUST be invoked on the generated operations to dispatch the request to the service.

Constructing a Client

A Config is required to construct a client. For most use cases, the aws-config crate should be used to automatically resolve this config using aws_config::load_from_env(), since this will resolve an SdkConfig which can be shared across multiple different AWS SDK clients. This config resolution process can be customized by calling aws_config::from_env() instead, which returns a ConfigLoader that uses the builder pattern to customize the default config.

In the simplest case, creating a client looks as follows:

let config = aws_config::load_from_env().await;
let client = aws_sdk_kafka::Client::new(&config);

Occasionally, SDKs may have additional service-specific that can be set on the Config that is absent from SdkConfig, or slightly different settings for a specific client may be desired. The Config struct implements From<&SdkConfig>, so setting these specific settings can be done as follows:

let sdk_config = aws_config::load_from_env().await;
let config = aws_sdk_kafka::config::Builder::from(&sdk_config)
    .some_service_specific_setting("value")
    .build();

See the aws-config docs and Config for more information on customizing configuration.

Note: Client construction is expensive due to connection thread pool initialization, and should be done once at application start-up.

Using the Client

A client has a function for every operation that can be performed by the service. For example, the BatchAssociateScramSecret operation has a Client::batch_associate_scram_secret, function which returns a builder for that operation. The fluent builder ultimately has a send() function that returns an async future that returns a result, as illustrated below:

let result = client.batch_associate_scram_secret()
    .cluster_arn("example")
    .send()
    .await;

The underlying HTTP requests that get made by this can be modified with the customize_operation function on the fluent builder. See the customize module for more information.

Implementations

impl Client

pub fn batch_associate_scram_secret( &self ) -> BatchAssociateScramSecretFluentBuilder

Constructs a fluent builder for the BatchAssociateScramSecret operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster to be updated.

  • secret_arn_list(Vec<String>) / set_secret_arn_list(Option<Vec<String>>):

    List of AWS Secrets Manager secret ARNs.

• On success, responds with BatchAssociateScramSecretOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • unprocessed_scram_secrets(Option<Vec<UnprocessedScramSecret>>):

    List of errors when associating secrets to cluster.

• On failure, responds with SdkError<BatchAssociateScramSecretError>

impl Client

pub fn batch_disassociate_scram_secret( &self ) -> BatchDisassociateScramSecretFluentBuilder

Constructs a fluent builder for the BatchDisassociateScramSecret operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster to be updated.

  • secret_arn_list(Vec<String>) / set_secret_arn_list(Option<Vec<String>>):

    List of AWS Secrets Manager secret ARNs.

• On success, responds with BatchDisassociateScramSecretOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • unprocessed_scram_secrets(Option<Vec<UnprocessedScramSecret>>):

    List of errors when disassociating secrets to cluster.

• On failure, responds with SdkError<BatchDisassociateScramSecretError>

impl Client

pub fn create_cluster(&self) -> CreateClusterFluentBuilder

Constructs a fluent builder for the CreateCluster operation.

• The fluent builder is configurable:
  • broker_node_group_info(BrokerNodeGroupInfo) / set_broker_node_group_info(Option<BrokerNodeGroupInfo>):

    Information about the broker nodes in the cluster.

  • client_authentication(ClientAuthentication) / set_client_authentication(Option<ClientAuthentication>):

    Includes all client authentication related information.

  • cluster_name(impl Into<String>) / set_cluster_name(Option<String>):

    The name of the cluster.

  • configuration_info(ConfigurationInfo) / set_configuration_info(Option<ConfigurationInfo>):

    Represents the configuration that you want MSK to use for the brokers in a cluster.

  • encryption_info(EncryptionInfo) / set_encryption_info(Option<EncryptionInfo>):

    Includes all encryption-related information.

  • enhanced_monitoring(EnhancedMonitoring) / set_enhanced_monitoring(Option<EnhancedMonitoring>):

    Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.

  • open_monitoring(OpenMonitoringInfo) / set_open_monitoring(Option<OpenMonitoringInfo>):

    The settings for open monitoring.

  • kafka_version(impl Into<String>) / set_kafka_version(Option<String>):

    The version of Apache Kafka.

  • logging_info(LoggingInfo) / set_logging_info(Option<LoggingInfo>): (undocumented)
  • number_of_broker_nodes(i32) / set_number_of_broker_nodes(Option<i32>):

    The number of broker nodes in the cluster.

  • tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):

    Create tags when creating the cluster.

  • storage_mode(StorageMode) / set_storage_mode(Option<StorageMode>):

    This controls storage mode for supported storage tiers.

• On success, responds with CreateClusterOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_name(Option<String>):

    The name of the MSK cluster.

  • state(Option<ClusterState>):

    The state of the cluster. The possible states are ACTIVE, CREATING, DELETING, FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.

• On failure, responds with SdkError<CreateClusterError>

impl Client

pub fn create_cluster_v2(&self) -> CreateClusterV2FluentBuilder

Constructs a fluent builder for the CreateClusterV2 operation.

• The fluent builder is configurable:
  • cluster_name(impl Into<String>) / set_cluster_name(Option<String>):

    The name of the cluster.

  • tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):

    A map of tags that you want the cluster to have.

  • provisioned(ProvisionedRequest) / set_provisioned(Option<ProvisionedRequest>):

    Information about the provisioned cluster.

  • serverless(ServerlessRequest) / set_serverless(Option<ServerlessRequest>):

    Information about the serverless cluster.

• On success, responds with CreateClusterV2Output with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_name(Option<String>):

    The name of the MSK cluster.

  • state(Option<ClusterState>):

    The state of the cluster. The possible states are ACTIVE, CREATING, DELETING, FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.

  • cluster_type(Option<ClusterType>):

    The type of the cluster. The possible states are PROVISIONED or SERVERLESS.

• On failure, responds with SdkError<CreateClusterV2Error>

impl Client

pub fn create_configuration(&self) -> CreateConfigurationFluentBuilder

Constructs a fluent builder for the CreateConfiguration operation.

• The fluent builder is configurable:
  • description(impl Into<String>) / set_description(Option<String>):

    The description of the configuration.

  • kafka_versions(Vec<String>) / set_kafka_versions(Option<Vec<String>>):

    The versions of Apache Kafka with which you can use this MSK configuration.

  • name(impl Into<String>) / set_name(Option<String>):

    The name of the configuration.

  • server_properties(Blob) / set_server_properties(Option<Blob>):

    Contents of the server.properties file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the AWS Management Console, the SDK, or the AWS CLI, the contents of server.properties can be in plaintext.

• On success, responds with CreateConfigurationOutput with field(s):
  • arn(Option<String>):

    The Amazon Resource Name (ARN) of the configuration.

  • creation_time(Option<DateTime>):

    The time when the configuration was created.

  • latest_revision(Option<ConfigurationRevision>):

    Latest revision of the configuration.

  • name(Option<String>):

    The name of the configuration.

  • state(Option<ConfigurationState>):

    The state of the configuration. The possible states are ACTIVE, DELETING, and DELETE_FAILED.

• On failure, responds with SdkError<CreateConfigurationError>

impl Client

pub fn delete_cluster(&self) -> DeleteClusterFluentBuilder

Constructs a fluent builder for the DeleteCluster operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The current version of the MSK cluster.

• On success, responds with DeleteClusterOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • state(Option<ClusterState>):

    The state of the cluster. The possible states are ACTIVE, CREATING, DELETING, FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.

• On failure, responds with SdkError<DeleteClusterError>

impl Client

pub fn delete_configuration(&self) -> DeleteConfigurationFluentBuilder

Constructs a fluent builder for the DeleteConfiguration operation.

• The fluent builder is configurable:
  • arn(impl Into<String>) / set_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies an MSK configuration.

• On success, responds with DeleteConfigurationOutput with field(s):
  • arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies an MSK configuration.

  • state(Option<ConfigurationState>):

    The state of the configuration. The possible states are ACTIVE, DELETING, and DELETE_FAILED.

• On failure, responds with SdkError<DeleteConfigurationError>

impl Client

pub fn describe_cluster(&self) -> DescribeClusterFluentBuilder

Constructs a fluent builder for the DescribeCluster operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

• On success, responds with DescribeClusterOutput with field(s):
  • cluster_info(Option<ClusterInfo>):

    The cluster information.

• On failure, responds with SdkError<DescribeClusterError>

impl Client

pub fn describe_cluster_operation( &self ) -> DescribeClusterOperationFluentBuilder

Constructs a fluent builder for the DescribeClusterOperation operation.

• The fluent builder is configurable:
  • cluster_operation_arn(impl Into<String>) / set_cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the MSK cluster operation.

• On success, responds with DescribeClusterOperationOutput with field(s):
  • cluster_operation_info(Option<ClusterOperationInfo>):

    Cluster operation information

• On failure, responds with SdkError<DescribeClusterOperationError>

impl Client

pub fn describe_cluster_v2(&self) -> DescribeClusterV2FluentBuilder

Constructs a fluent builder for the DescribeClusterV2 operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

• On success, responds with DescribeClusterV2Output with field(s):
  • cluster_info(Option<Cluster>):

    The cluster information.

• On failure, responds with SdkError<DescribeClusterV2Error>

impl Client

pub fn describe_configuration(&self) -> DescribeConfigurationFluentBuilder

Constructs a fluent builder for the DescribeConfiguration operation.

• The fluent builder is configurable:
  • arn(impl Into<String>) / set_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies an MSK configuration and all of its revisions.

• On success, responds with DescribeConfigurationOutput with field(s):
  • arn(Option<String>):

    The Amazon Resource Name (ARN) of the configuration.

  • creation_time(Option<DateTime>):

    The time when the configuration was created.

  • description(Option<String>):

    The description of the configuration.

  • kafka_versions(Option<Vec<String>>):

    The versions of Apache Kafka with which you can use this MSK configuration.

  • latest_revision(Option<ConfigurationRevision>):

    Latest revision of the configuration.

  • name(Option<String>):

    The name of the configuration.

  • state(Option<ConfigurationState>):

    The state of the configuration. The possible states are ACTIVE, DELETING, and DELETE_FAILED.

• On failure, responds with SdkError<DescribeConfigurationError>

impl Client

pub fn describe_configuration_revision( &self ) -> DescribeConfigurationRevisionFluentBuilder

Constructs a fluent builder for the DescribeConfigurationRevision operation.

• The fluent builder is configurable:
  • arn(impl Into<String>) / set_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies an MSK configuration and all of its revisions.

  • revision(i64) / set_revision(Option<i64>):

    A string that uniquely identifies a revision of an MSK configuration.

• On success, responds with DescribeConfigurationRevisionOutput with field(s):
  • arn(Option<String>):

    The Amazon Resource Name (ARN) of the configuration.

  • creation_time(Option<DateTime>):

    The time when the configuration was created.

  • description(Option<String>):

    The description of the configuration.

  • revision(i64):

    The revision number.

  • server_properties(Option<Blob>):

    Contents of the server.properties file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the AWS Management Console, the SDK, or the AWS CLI, the contents of server.properties can be in plaintext.

• On failure, responds with SdkError<DescribeConfigurationRevisionError>

impl Client

pub fn get_bootstrap_brokers(&self) -> GetBootstrapBrokersFluentBuilder

Constructs a fluent builder for the GetBootstrapBrokers operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

• On success, responds with GetBootstrapBrokersOutput with field(s):
  • bootstrap_broker_string(Option<String>):

    A string containing one or more hostname:port pairs.

  • bootstrap_broker_string_tls(Option<String>):

    A string containing one or more DNS names (or IP) and TLS port pairs.

  • bootstrap_broker_string_sasl_scram(Option<String>):

    A string containing one or more DNS names (or IP) and Sasl Scram port pairs.

  • bootstrap_broker_string_sasl_iam(Option<String>):

    A string that contains one or more DNS names (or IP addresses) and SASL IAM port pairs.

  • bootstrap_broker_string_public_tls(Option<String>):

    A string containing one or more DNS names (or IP) and TLS port pairs.

  • bootstrap_broker_string_public_sasl_scram(Option<String>):

    A string containing one or more DNS names (or IP) and Sasl Scram port pairs.

  • bootstrap_broker_string_public_sasl_iam(Option<String>):

    A string that contains one or more DNS names (or IP addresses) and SASL IAM port pairs.

• On failure, responds with SdkError<GetBootstrapBrokersError>

impl Client

pub fn get_compatible_kafka_versions( &self ) -> GetCompatibleKafkaVersionsFluentBuilder

Constructs a fluent builder for the GetCompatibleKafkaVersions operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster check.

• On success, responds with GetCompatibleKafkaVersionsOutput with field(s):
  • compatible_kafka_versions(Option<Vec<CompatibleKafkaVersion>>):

    A list of CompatibleKafkaVersion objects.

• On failure, responds with SdkError<GetCompatibleKafkaVersionsError>

impl Client

pub fn list_cluster_operations(&self) -> ListClusterOperationsFluentBuilder

Constructs a fluent builder for the ListClusterOperations operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListClusterOperationsOutput with field(s):
  • cluster_operation_info_list(Option<Vec<ClusterOperationInfo>>):

    An array of cluster operation information objects.

  • next_token(Option<String>):

    If the response of ListClusterOperations is truncated, it returns a NextToken in the response. This Nexttoken should be sent in the subsequent request to ListClusterOperations.

• On failure, responds with SdkError<ListClusterOperationsError>

impl Client

pub fn list_clusters(&self) -> ListClustersFluentBuilder

Constructs a fluent builder for the ListClusters operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • cluster_name_filter(impl Into<String>) / set_cluster_name_filter(Option<String>):

    Specify a prefix of the name of the clusters that you want to list. The service lists all the clusters whose names start with this prefix.

  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListClustersOutput with field(s):
  • cluster_info_list(Option<Vec<ClusterInfo>>):

    Information on each of the MSK clusters in the response.

  • next_token(Option<String>):

    The paginated results marker. When the result of a ListClusters operation is truncated, the call returns NextToken in the response. To get another batch of clusters, provide this token in your next request.

• On failure, responds with SdkError<ListClustersError>

impl Client

pub fn list_clusters_v2(&self) -> ListClustersV2FluentBuilder

Constructs a fluent builder for the ListClustersV2 operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • cluster_name_filter(impl Into<String>) / set_cluster_name_filter(Option<String>):

    Specify a prefix of the names of the clusters that you want to list. The service lists all the clusters whose names start with this prefix.

  • cluster_type_filter(impl Into<String>) / set_cluster_type_filter(Option<String>):

    Specify either PROVISIONED or SERVERLESS.

  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListClustersV2Output with field(s):
  • cluster_info_list(Option<Vec<Cluster>>):

    Information on each of the MSK clusters in the response.

  • next_token(Option<String>):

    The paginated results marker. When the result of a ListClusters operation is truncated, the call returns NextToken in the response. To get another batch of clusters, provide this token in your next request.

• On failure, responds with SdkError<ListClustersV2Error>

impl Client

pub fn list_configuration_revisions( &self ) -> ListConfigurationRevisionsFluentBuilder

Constructs a fluent builder for the ListConfigurationRevisions operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • arn(impl Into<String>) / set_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies an MSK configuration and all of its revisions.

  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListConfigurationRevisionsOutput with field(s):
  • next_token(Option<String>):

    Paginated results marker.

  • revisions(Option<Vec<ConfigurationRevision>>):

    List of ConfigurationRevision objects.

• On failure, responds with SdkError<ListConfigurationRevisionsError>

impl Client

pub fn list_configurations(&self) -> ListConfigurationsFluentBuilder

Constructs a fluent builder for the ListConfigurations operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListConfigurationsOutput with field(s):
  • configurations(Option<Vec<Configuration>>):

    An array of MSK configurations.

  • next_token(Option<String>):

    The paginated results marker. When the result of a ListConfigurations operation is truncated, the call returns NextToken in the response. To get another batch of configurations, provide this token in your next request.

• On failure, responds with SdkError<ListConfigurationsError>

impl Client

pub fn list_kafka_versions(&self) -> ListKafkaVersionsFluentBuilder

Constructs a fluent builder for the ListKafkaVersions operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListKafkaVersionsOutput with field(s):
  • kafka_versions(Option<Vec<KafkaVersion>>): (undocumented)
  • next_token(Option<String>): (undocumented)
• On failure, responds with SdkError<ListKafkaVersionsError>

impl Client

pub fn list_nodes(&self) -> ListNodesFluentBuilder

Constructs a fluent builder for the ListNodes operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • max_results(i32) / set_max_results(Option<i32>):

    The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.

• On success, responds with ListNodesOutput with field(s):
  • next_token(Option<String>):

    The paginated results marker. When the result of a ListNodes operation is truncated, the call returns NextToken in the response. To get another batch of nodes, provide this token in your next request.

  • node_info_list(Option<Vec<NodeInfo>>):

    List containing a NodeInfo object.

• On failure, responds with SdkError<ListNodesError>

impl Client

pub fn list_scram_secrets(&self) -> ListScramSecretsFluentBuilder

Constructs a fluent builder for the ListScramSecrets operation. This operation supports pagination; See into_paginator().

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The arn of the cluster.

  • max_results(i32) / set_max_results(Option<i32>):

    The maxResults of the query.

  • next_token(impl Into<String>) / set_next_token(Option<String>):

    The nextToken of the query.

• On success, responds with ListScramSecretsOutput with field(s):
  • next_token(Option<String>):

    Paginated results marker.

  • secret_arn_list(Option<Vec<String>>):

    The list of scram secrets associated with the cluster.

• On failure, responds with SdkError<ListScramSecretsError>

impl Client

pub fn list_tags_for_resource(&self) -> ListTagsForResourceFluentBuilder

Constructs a fluent builder for the ListTagsForResource operation.

• The fluent builder is configurable:
  • resource_arn(impl Into<String>) / set_resource_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the resource that’s associated with the tags.

• On success, responds with ListTagsForResourceOutput with field(s):
  • tags(Option<HashMap<String, String>>):

    The key-value pair for the resource tag.

• On failure, responds with SdkError<ListTagsForResourceError>

impl Client

pub fn reboot_broker(&self) -> RebootBrokerFluentBuilder

Constructs a fluent builder for the RebootBroker operation.

• The fluent builder is configurable:
  • broker_ids(Vec<String>) / set_broker_ids(Option<Vec<String>>):

    The list of broker IDs to be rebooted. The reboot-broker operation supports rebooting one broker at a time.

  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster to be updated.

• On success, responds with RebootBrokerOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<RebootBrokerError>

impl Client

pub fn tag_resource(&self) -> TagResourceFluentBuilder

Constructs a fluent builder for the TagResource operation.

• The fluent builder is configurable:
  • resource_arn(impl Into<String>) / set_resource_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the resource that’s associated with the tags.

  • tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):

    The key-value pair for the resource tag.

• On success, responds with TagResourceOutput
• On failure, responds with SdkError<TagResourceError>

impl Client

pub fn untag_resource(&self) -> UntagResourceFluentBuilder

Constructs a fluent builder for the UntagResource operation.

• The fluent builder is configurable:
  • resource_arn(impl Into<String>) / set_resource_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the resource that’s associated with the tags.

  • tag_keys(Vec<String>) / set_tag_keys(Option<Vec<String>>):

    Tag keys must be unique for a given cluster. In addition, the following restrictions apply:

    • Each tag key must be unique. If you add a tag with a key that’s already in use, your new tag overwrites the existing key-value pair.

    • You can’t start a tag key with aws: because this prefix is reserved for use by AWS. AWS creates tags that begin with this prefix on your behalf, but you can’t edit or delete them.

    • Tag keys must be between 1 and 128 Unicode characters in length.

    • Tag keys must consist of the following characters: Unicode letters, digits, white space, and the following special characters: _ . / = + - @.

• On success, responds with UntagResourceOutput
• On failure, responds with SdkError<UntagResourceError>

impl Client

pub fn update_broker_count(&self) -> UpdateBrokerCountFluentBuilder

Constructs a fluent builder for the UpdateBrokerCount operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of cluster to update from. A successful operation will then generate a new version.

  • target_number_of_broker_nodes(i32) / set_target_number_of_broker_nodes(Option<i32>):

    The number of broker nodes that you want the cluster to have after this operation completes successfully.

• On success, responds with UpdateBrokerCountOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateBrokerCountError>

impl Client

pub fn update_broker_storage(&self) -> UpdateBrokerStorageFluentBuilder

Constructs a fluent builder for the UpdateBrokerStorage operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of cluster to update from. A successful operation will then generate a new version.

  • target_broker_ebs_volume_info(Vec<BrokerEbsVolumeInfo>) / set_target_broker_ebs_volume_info(Option<Vec<BrokerEbsVolumeInfo>>):

    Describes the target volume size and the ID of the broker to apply the update to.

• On success, responds with UpdateBrokerStorageOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateBrokerStorageError>

impl Client

pub fn update_broker_type(&self) -> UpdateBrokerTypeFluentBuilder

Constructs a fluent builder for the UpdateBrokerType operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The cluster version that you want to change. After this operation completes successfully, the cluster will have a new version.

  • target_instance_type(impl Into<String>) / set_target_instance_type(Option<String>):

    The Amazon MSK broker type that you want all of the brokers in this cluster to be.

• On success, responds with UpdateBrokerTypeOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateBrokerTypeError>

impl Client

pub fn update_cluster_configuration( &self ) -> UpdateClusterConfigurationFluentBuilder

Constructs a fluent builder for the UpdateClusterConfiguration operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • configuration_info(ConfigurationInfo) / set_configuration_info(Option<ConfigurationInfo>):

    Represents the configuration that you want MSK to use for the brokers in a cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of the cluster that needs to be updated.

• On success, responds with UpdateClusterConfigurationOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateClusterConfigurationError>

impl Client

pub fn update_cluster_kafka_version( &self ) -> UpdateClusterKafkaVersionFluentBuilder

Constructs a fluent builder for the UpdateClusterKafkaVersion operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster to be updated.

  • configuration_info(ConfigurationInfo) / set_configuration_info(Option<ConfigurationInfo>):

    The custom configuration that should be applied on the new version of cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    Current cluster version.

  • target_kafka_version(impl Into<String>) / set_target_kafka_version(Option<String>):

    Target Kafka version.

• On success, responds with UpdateClusterKafkaVersionOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateClusterKafkaVersionError>

impl Client

pub fn update_configuration(&self) -> UpdateConfigurationFluentBuilder

Constructs a fluent builder for the UpdateConfiguration operation.

• The fluent builder is configurable:
  • arn(impl Into<String>) / set_arn(Option<String>):

    The Amazon Resource Name (ARN) of the configuration.

  • description(impl Into<String>) / set_description(Option<String>):

    The description of the configuration revision.

  • server_properties(Blob) / set_server_properties(Option<Blob>):

    Contents of the server.properties file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the AWS Management Console, the SDK, or the AWS CLI, the contents of server.properties can be in plaintext.

• On success, responds with UpdateConfigurationOutput with field(s):
  • arn(Option<String>):

    The Amazon Resource Name (ARN) of the configuration.

  • latest_revision(Option<ConfigurationRevision>):

    Latest revision of the configuration.

• On failure, responds with SdkError<UpdateConfigurationError>

impl Client

pub fn update_connectivity(&self) -> UpdateConnectivityFluentBuilder

Constructs a fluent builder for the UpdateConnectivity operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the configuration.

  • connectivity_info(ConnectivityInfo) / set_connectivity_info(Option<ConnectivityInfo>):

    Information about the broker access configuration.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of the MSK cluster to update. Cluster versions aren’t simple numbers. You can describe an MSK cluster to find its version. When this update operation is successful, it generates a new cluster version.

• On success, responds with UpdateConnectivityOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateConnectivityError>

impl Client

pub fn update_monitoring(&self) -> UpdateMonitoringFluentBuilder

Constructs a fluent builder for the UpdateMonitoring operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of the MSK cluster to update. Cluster versions aren’t simple numbers. You can describe an MSK cluster to find its version. When this update operation is successful, it generates a new cluster version.

  • enhanced_monitoring(EnhancedMonitoring) / set_enhanced_monitoring(Option<EnhancedMonitoring>):

    Specifies which Apache Kafka metrics Amazon MSK gathers and sends to Amazon CloudWatch for this cluster.

  • open_monitoring(OpenMonitoringInfo) / set_open_monitoring(Option<OpenMonitoringInfo>):

    The settings for open monitoring.

  • logging_info(LoggingInfo) / set_logging_info(Option<LoggingInfo>): (undocumented)
• On success, responds with UpdateMonitoringOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateMonitoringError>

impl Client

pub fn update_security(&self) -> UpdateSecurityFluentBuilder

Constructs a fluent builder for the UpdateSecurity operation.

• The fluent builder is configurable:
  • client_authentication(ClientAuthentication) / set_client_authentication(Option<ClientAuthentication>):

    Includes all client authentication related information.

  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) that uniquely identifies the cluster.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of the MSK cluster to update. Cluster versions aren’t simple numbers. You can describe an MSK cluster to find its version. When this update operation is successful, it generates a new cluster version.

  • encryption_info(EncryptionInfo) / set_encryption_info(Option<EncryptionInfo>):

    Includes all encryption-related information.

• On success, responds with UpdateSecurityOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateSecurityError>

impl Client

pub fn update_storage(&self) -> UpdateStorageFluentBuilder

Constructs a fluent builder for the UpdateStorage operation.

• The fluent builder is configurable:
  • cluster_arn(impl Into<String>) / set_cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster to be updated.

  • current_version(impl Into<String>) / set_current_version(Option<String>):

    The version of cluster to update from. A successful operation will then generate a new version.

  • provisioned_throughput(ProvisionedThroughput) / set_provisioned_throughput(Option<ProvisionedThroughput>):

    EBS volume provisioned throughput information.

  • storage_mode(StorageMode) / set_storage_mode(Option<StorageMode>):

    Controls storage mode for supported storage tiers.

  • volume_size_gb(i32) / set_volume_size_gb(Option<i32>):

    size of the EBS volume to update.

• On success, responds with UpdateStorageOutput with field(s):
  • cluster_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster.

  • cluster_operation_arn(Option<String>):

    The Amazon Resource Name (ARN) of the cluster operation.

• On failure, responds with SdkError<UpdateStorageError>

impl Client

pub fn with_config( client: Client<DynConnector, DynMiddleware<DynConnector>>, conf: Config ) -> Self

Creates a client with the given service configuration.

pub fn conf(&self) -> &Config

Returns the client’s configuration.

impl Client

pub fn new(sdk_config: &SdkConfig) -> Self

Creates a new client from an SDK Config.

Panics

• This method will panic if the sdk_config is missing an async sleep implementation. If you experience this panic, set the sleep_impl on the Config passed into this function to fix it.
• This method will panic if the sdk_config is missing an HTTP connector. If you experience this panic, set the http_connector on the Config passed into this function to fix it.

pub fn from_conf(conf: Config) -> Self

Creates a new client from the service Config.

Panics

• This method will panic if the conf is missing an async sleep implementation. If you experience this panic, set the sleep_impl on the Config passed into this function to fix it.
• This method will panic if the conf is missing an HTTP connector. If you experience this panic, set the http_connector on the Config passed into this function to fix it.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<Client<DynConnector, DynMiddleware<DynConnector>, Standard>> for Client

fn from(client: Client<DynConnector, DynMiddleware<DynConnector>>) -> Self

Converts to this type from the input type.