@Generated(value="software.amazon.awssdk:codegen") @ThreadSafe public interface KafkaAsyncClient extends SdkClient
builder() method.
The operations for managing an Amazon MSK cluster.
| Modifier and Type | Field and Description |
|---|---|
static String |
SERVICE_METADATA_ID
Value for looking up the service's metadata from the
ServiceMetadataProvider. |
static String |
SERVICE_NAME |
| Modifier and Type | Method and Description |
|---|---|
default CompletableFuture<BatchAssociateScramSecretResponse> |
batchAssociateScramSecret(BatchAssociateScramSecretRequest batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
|
default CompletableFuture<BatchAssociateScramSecretResponse> |
batchAssociateScramSecret(Consumer<BatchAssociateScramSecretRequest.Builder> batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
|
default CompletableFuture<BatchDisassociateScramSecretResponse> |
batchDisassociateScramSecret(BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
|
default CompletableFuture<BatchDisassociateScramSecretResponse> |
batchDisassociateScramSecret(Consumer<BatchDisassociateScramSecretRequest.Builder> batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
|
static KafkaAsyncClientBuilder |
builder()
Create a builder that can be used to configure and create a
KafkaAsyncClient. |
static KafkaAsyncClient |
create()
Create a
KafkaAsyncClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider. |
default CompletableFuture<CreateClusterResponse> |
createCluster(Consumer<CreateClusterRequest.Builder> createClusterRequest)
Creates a new MSK cluster.
|
default CompletableFuture<CreateClusterResponse> |
createCluster(CreateClusterRequest createClusterRequest)
Creates a new MSK cluster.
|
default CompletableFuture<CreateClusterV2Response> |
createClusterV2(Consumer<CreateClusterV2Request.Builder> createClusterV2Request)
Creates a new MSK cluster.
|
default CompletableFuture<CreateClusterV2Response> |
createClusterV2(CreateClusterV2Request createClusterV2Request)
Creates a new MSK cluster.
|
default CompletableFuture<CreateConfigurationResponse> |
createConfiguration(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest)
Creates a new MSK configuration.
|
default CompletableFuture<CreateConfigurationResponse> |
createConfiguration(CreateConfigurationRequest createConfigurationRequest)
Creates a new MSK configuration.
|
default CompletableFuture<DeleteClusterResponse> |
deleteCluster(Consumer<DeleteClusterRequest.Builder> deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
|
default CompletableFuture<DeleteClusterResponse> |
deleteCluster(DeleteClusterRequest deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
|
default CompletableFuture<DeleteConfigurationResponse> |
deleteConfiguration(Consumer<DeleteConfigurationRequest.Builder> deleteConfigurationRequest)
Deletes an MSK Configuration.
|
default CompletableFuture<DeleteConfigurationResponse> |
deleteConfiguration(DeleteConfigurationRequest deleteConfigurationRequest)
Deletes an MSK Configuration.
|
default CompletableFuture<DescribeClusterResponse> |
describeCluster(Consumer<DescribeClusterRequest.Builder> describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default CompletableFuture<DescribeClusterResponse> |
describeCluster(DescribeClusterRequest describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default CompletableFuture<DescribeClusterOperationResponse> |
describeClusterOperation(Consumer<DescribeClusterOperationRequest.Builder> describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
|
default CompletableFuture<DescribeClusterOperationResponse> |
describeClusterOperation(DescribeClusterOperationRequest describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
|
default CompletableFuture<DescribeClusterV2Response> |
describeClusterV2(Consumer<DescribeClusterV2Request.Builder> describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default CompletableFuture<DescribeClusterV2Response> |
describeClusterV2(DescribeClusterV2Request describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default CompletableFuture<DescribeConfigurationResponse> |
describeConfiguration(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest)
Returns a description of this MSK configuration.
|
default CompletableFuture<DescribeConfigurationResponse> |
describeConfiguration(DescribeConfigurationRequest describeConfigurationRequest)
Returns a description of this MSK configuration.
|
default CompletableFuture<DescribeConfigurationRevisionResponse> |
describeConfigurationRevision(Consumer<DescribeConfigurationRevisionRequest.Builder> describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
|
default CompletableFuture<DescribeConfigurationRevisionResponse> |
describeConfigurationRevision(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
|
default CompletableFuture<GetBootstrapBrokersResponse> |
getBootstrapBrokers(Consumer<GetBootstrapBrokersRequest.Builder> getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
|
default CompletableFuture<GetBootstrapBrokersResponse> |
getBootstrapBrokers(GetBootstrapBrokersRequest getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
|
default CompletableFuture<GetCompatibleKafkaVersionsResponse> |
getCompatibleKafkaVersions(Consumer<GetCompatibleKafkaVersionsRequest.Builder> getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
|
default CompletableFuture<GetCompatibleKafkaVersionsResponse> |
getCompatibleKafkaVersions(GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
|
default CompletableFuture<ListClusterOperationsResponse> |
listClusterOperations(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default CompletableFuture<ListClusterOperationsResponse> |
listClusterOperations(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default ListClusterOperationsPublisher |
listClusterOperationsPaginator(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default ListClusterOperationsPublisher |
listClusterOperationsPaginator(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default CompletableFuture<ListClustersResponse> |
listClusters()
Returns a list of all the MSK clusters in the current Region.
|
default CompletableFuture<ListClustersResponse> |
listClusters(Consumer<ListClustersRequest.Builder> listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default CompletableFuture<ListClustersResponse> |
listClusters(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersPublisher |
listClustersPaginator()
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersPublisher |
listClustersPaginator(Consumer<ListClustersRequest.Builder> listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersPublisher |
listClustersPaginator(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default CompletableFuture<ListClustersV2Response> |
listClustersV2(Consumer<ListClustersV2Request.Builder> listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default CompletableFuture<ListClustersV2Response> |
listClustersV2(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersV2Publisher |
listClustersV2Paginator(Consumer<ListClustersV2Request.Builder> listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersV2Publisher |
listClustersV2Paginator(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default CompletableFuture<ListConfigurationRevisionsResponse> |
listConfigurationRevisions(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default CompletableFuture<ListConfigurationRevisionsResponse> |
listConfigurationRevisions(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationRevisionsPublisher |
listConfigurationRevisionsPaginator(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationRevisionsPublisher |
listConfigurationRevisionsPaginator(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default CompletableFuture<ListConfigurationsResponse> |
listConfigurations(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default CompletableFuture<ListConfigurationsResponse> |
listConfigurations(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationsPublisher |
listConfigurationsPaginator(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationsPublisher |
listConfigurationsPaginator(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default CompletableFuture<ListKafkaVersionsResponse> |
listKafkaVersions(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default CompletableFuture<ListKafkaVersionsResponse> |
listKafkaVersions(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default ListKafkaVersionsPublisher |
listKafkaVersionsPaginator(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default ListKafkaVersionsPublisher |
listKafkaVersionsPaginator(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default CompletableFuture<ListNodesResponse> |
listNodes(Consumer<ListNodesRequest.Builder> listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default CompletableFuture<ListNodesResponse> |
listNodes(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default ListNodesPublisher |
listNodesPaginator(Consumer<ListNodesRequest.Builder> listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default ListNodesPublisher |
listNodesPaginator(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default CompletableFuture<ListScramSecretsResponse> |
listScramSecrets(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default CompletableFuture<ListScramSecretsResponse> |
listScramSecrets(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default ListScramSecretsPublisher |
listScramSecretsPaginator(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default ListScramSecretsPublisher |
listScramSecretsPaginator(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default CompletableFuture<ListTagsForResourceResponse> |
listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
|
default CompletableFuture<ListTagsForResourceResponse> |
listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
|
default CompletableFuture<RebootBrokerResponse> |
rebootBroker(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest)
Reboots brokers.
|
default CompletableFuture<RebootBrokerResponse> |
rebootBroker(RebootBrokerRequest rebootBrokerRequest)
Reboots brokers.
|
default CompletableFuture<TagResourceResponse> |
tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)
Adds tags to the specified MSK resource.
|
default CompletableFuture<TagResourceResponse> |
tagResource(TagResourceRequest tagResourceRequest)
Adds tags to the specified MSK resource.
|
default CompletableFuture<UntagResourceResponse> |
untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
|
default CompletableFuture<UntagResourceResponse> |
untagResource(UntagResourceRequest untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
|
default CompletableFuture<UpdateBrokerCountResponse> |
updateBrokerCount(Consumer<UpdateBrokerCountRequest.Builder> updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
|
default CompletableFuture<UpdateBrokerCountResponse> |
updateBrokerCount(UpdateBrokerCountRequest updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
|
default CompletableFuture<UpdateBrokerStorageResponse> |
updateBrokerStorage(Consumer<UpdateBrokerStorageRequest.Builder> updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
|
default CompletableFuture<UpdateBrokerStorageResponse> |
updateBrokerStorage(UpdateBrokerStorageRequest updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
|
default CompletableFuture<UpdateBrokerTypeResponse> |
updateBrokerType(Consumer<UpdateBrokerTypeRequest.Builder> updateBrokerTypeRequest)
Updates EC2 instance type.
|
default CompletableFuture<UpdateBrokerTypeResponse> |
updateBrokerType(UpdateBrokerTypeRequest updateBrokerTypeRequest)
Updates EC2 instance type.
|
default CompletableFuture<UpdateClusterConfigurationResponse> |
updateClusterConfiguration(Consumer<UpdateClusterConfigurationRequest.Builder> updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
|
default CompletableFuture<UpdateClusterConfigurationResponse> |
updateClusterConfiguration(UpdateClusterConfigurationRequest updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
|
default CompletableFuture<UpdateClusterKafkaVersionResponse> |
updateClusterKafkaVersion(Consumer<UpdateClusterKafkaVersionRequest.Builder> updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
|
default CompletableFuture<UpdateClusterKafkaVersionResponse> |
updateClusterKafkaVersion(UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
|
default CompletableFuture<UpdateConfigurationResponse> |
updateConfiguration(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest)
Updates an MSK configuration.
|
default CompletableFuture<UpdateConfigurationResponse> |
updateConfiguration(UpdateConfigurationRequest updateConfigurationRequest)
Updates an MSK configuration.
|
default CompletableFuture<UpdateConnectivityResponse> |
updateConnectivity(Consumer<UpdateConnectivityRequest.Builder> updateConnectivityRequest)
Updates the cluster's connectivity configuration.
|
default CompletableFuture<UpdateConnectivityResponse> |
updateConnectivity(UpdateConnectivityRequest updateConnectivityRequest)
Updates the cluster's connectivity configuration.
|
default CompletableFuture<UpdateMonitoringResponse> |
updateMonitoring(Consumer<UpdateMonitoringRequest.Builder> updateMonitoringRequest)
Updates the monitoring settings for the cluster.
|
default CompletableFuture<UpdateMonitoringResponse> |
updateMonitoring(UpdateMonitoringRequest updateMonitoringRequest)
Updates the monitoring settings for the cluster.
|
default CompletableFuture<UpdateSecurityResponse> |
updateSecurity(Consumer<UpdateSecurityRequest.Builder> updateSecurityRequest)
Updates the security settings for the cluster.
|
default CompletableFuture<UpdateSecurityResponse> |
updateSecurity(UpdateSecurityRequest updateSecurityRequest)
Updates the security settings for the cluster.
|
serviceNameclosestatic final String SERVICE_NAME
static final String SERVICE_METADATA_ID
ServiceMetadataProvider.static KafkaAsyncClient create()
KafkaAsyncClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider.static KafkaAsyncClientBuilder builder()
KafkaAsyncClient.default CompletableFuture<BatchAssociateScramSecretResponse> batchAssociateScramSecret(BatchAssociateScramSecretRequest batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecretRequest - Associates sasl scram secrets to cluster.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<BatchAssociateScramSecretResponse> batchAssociateScramSecret(Consumer<BatchAssociateScramSecretRequest.Builder> batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
This is a convenience which creates an instance of the BatchAssociateScramSecretRequest.Builder avoiding
the need to create one manually via BatchAssociateScramSecretRequest.builder()
batchAssociateScramSecretRequest - A Consumer that will call methods on BatchAssociateScramSecretRequest.Builder to create a
request.
Associates sasl scram secrets to cluster.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<BatchDisassociateScramSecretResponse> batchDisassociateScramSecret(BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecretRequest - Disassociates sasl scram secrets to cluster.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<BatchDisassociateScramSecretResponse> batchDisassociateScramSecret(Consumer<BatchDisassociateScramSecretRequest.Builder> batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
This is a convenience which creates an instance of the BatchDisassociateScramSecretRequest.Builder
avoiding the need to create one manually via BatchDisassociateScramSecretRequest.builder()
batchDisassociateScramSecretRequest - A Consumer that will call methods on BatchDisassociateScramSecretRequest.Builder to create
a request.
Disassociates sasl scram secrets to cluster.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<CreateClusterResponse> createCluster(CreateClusterRequest createClusterRequest)
Creates a new MSK cluster.
createClusterRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
503 response
429 response
This cluster name already exists. Retry your request using another name.
default CompletableFuture<CreateClusterResponse> createCluster(Consumer<CreateClusterRequest.Builder> createClusterRequest)
Creates a new MSK cluster.
This is a convenience which creates an instance of the CreateClusterRequest.Builder avoiding the need to
create one manually via CreateClusterRequest.builder()
createClusterRequest - A Consumer that will call methods on CreateClusterRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
503 response
429 response
This cluster name already exists. Retry your request using another name.
default CompletableFuture<CreateClusterV2Response> createClusterV2(CreateClusterV2Request createClusterV2Request)
Creates a new MSK cluster.
createClusterV2Request - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
503 response
429 response
This cluster name already exists. Retry your request using another name.
default CompletableFuture<CreateClusterV2Response> createClusterV2(Consumer<CreateClusterV2Request.Builder> createClusterV2Request)
Creates a new MSK cluster.
This is a convenience which creates an instance of the CreateClusterV2Request.Builder avoiding the need
to create one manually via CreateClusterV2Request.builder()
createClusterV2Request - A Consumer that will call methods on CreateClusterV2Request.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
503 response
429 response
This cluster name already exists. Retry your request using another name.
default CompletableFuture<CreateConfigurationResponse> createConfiguration(CreateConfigurationRequest createConfigurationRequest)
Creates a new MSK configuration.
createConfigurationRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
503 response
429 response
This cluster name already exists. Retry your request using another name.
default CompletableFuture<CreateConfigurationResponse> createConfiguration(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest)
Creates a new MSK configuration.
This is a convenience which creates an instance of the CreateConfigurationRequest.Builder avoiding the
need to create one manually via CreateConfigurationRequest.builder()
createConfigurationRequest - A Consumer that will call methods on CreateConfigurationRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
503 response
429 response
This cluster name already exists. Retry your request using another name.
default CompletableFuture<DeleteClusterResponse> deleteCluster(DeleteClusterRequest deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteClusterRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DeleteClusterResponse> deleteCluster(Consumer<DeleteClusterRequest.Builder> deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
This is a convenience which creates an instance of the DeleteClusterRequest.Builder avoiding the need to
create one manually via DeleteClusterRequest.builder()
deleteClusterRequest - A Consumer that will call methods on DeleteClusterRequest.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DeleteConfigurationResponse> deleteConfiguration(DeleteConfigurationRequest deleteConfigurationRequest)
Deletes an MSK Configuration.
deleteConfigurationRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DeleteConfigurationResponse> deleteConfiguration(Consumer<DeleteConfigurationRequest.Builder> deleteConfigurationRequest)
Deletes an MSK Configuration.
This is a convenience which creates an instance of the DeleteConfigurationRequest.Builder avoiding the
need to create one manually via DeleteConfigurationRequest.builder()
deleteConfigurationRequest - A Consumer that will call methods on DeleteConfigurationRequest.Builder to create a
request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeClusterResponse> describeCluster(DescribeClusterRequest describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeClusterResponse> describeCluster(Consumer<DescribeClusterRequest.Builder> describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
This is a convenience which creates an instance of the DescribeClusterRequest.Builder avoiding the need
to create one manually via DescribeClusterRequest.builder()
describeClusterRequest - A Consumer that will call methods on DescribeClusterRequest.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeClusterOperationResponse> describeClusterOperation(DescribeClusterOperationRequest describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeClusterOperationResponse> describeClusterOperation(Consumer<DescribeClusterOperationRequest.Builder> describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
This is a convenience which creates an instance of the DescribeClusterOperationRequest.Builder avoiding
the need to create one manually via DescribeClusterOperationRequest.builder()
describeClusterOperationRequest - A Consumer that will call methods on DescribeClusterOperationRequest.Builder to create a
request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeClusterV2Response> describeClusterV2(DescribeClusterV2Request describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2Request - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeClusterV2Response> describeClusterV2(Consumer<DescribeClusterV2Request.Builder> describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
This is a convenience which creates an instance of the DescribeClusterV2Request.Builder avoiding the need
to create one manually via DescribeClusterV2Request.builder()
describeClusterV2Request - A Consumer that will call methods on DescribeClusterV2Request.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<DescribeConfigurationResponse> describeConfiguration(DescribeConfigurationRequest describeConfigurationRequest)
Returns a description of this MSK configuration.
describeConfigurationRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<DescribeConfigurationResponse> describeConfiguration(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest)
Returns a description of this MSK configuration.
This is a convenience which creates an instance of the DescribeConfigurationRequest.Builder avoiding the
need to create one manually via DescribeConfigurationRequest.builder()
describeConfigurationRequest - A Consumer that will call methods on DescribeConfigurationRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<DescribeConfigurationRevisionResponse> describeConfigurationRevision(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
describeConfigurationRevisionRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<DescribeConfigurationRevisionResponse> describeConfigurationRevision(Consumer<DescribeConfigurationRevisionRequest.Builder> describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
This is a convenience which creates an instance of the DescribeConfigurationRevisionRequest.Builder
avoiding the need to create one manually via DescribeConfigurationRevisionRequest.builder()
describeConfigurationRevisionRequest - A Consumer that will call methods on DescribeConfigurationRevisionRequest.Builder to
create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<GetBootstrapBrokersResponse> getBootstrapBrokers(GetBootstrapBrokersRequest getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
getBootstrapBrokersRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
This cluster name already exists. Retry your request using another name.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<GetBootstrapBrokersResponse> getBootstrapBrokers(Consumer<GetBootstrapBrokersRequest.Builder> getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
This is a convenience which creates an instance of the GetBootstrapBrokersRequest.Builder avoiding the
need to create one manually via GetBootstrapBrokersRequest.builder()
getBootstrapBrokersRequest - A Consumer that will call methods on GetBootstrapBrokersRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
This cluster name already exists. Retry your request using another name.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<GetCompatibleKafkaVersionsResponse> getCompatibleKafkaVersions(GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersionsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
nThe request is not authorized. The provided credentials couldn't be validated.
nThere was an unexpected internal server error. Retrying your request might resolve the issue.
nAccess forbidden. Check your credentials and then retry your request.
nThe resource could not be found due to incorrect input. Correct the input, then retry the request.
n503 response
n429 response
ndefault CompletableFuture<GetCompatibleKafkaVersionsResponse> getCompatibleKafkaVersions(Consumer<GetCompatibleKafkaVersionsRequest.Builder> getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
This is a convenience which creates an instance of the GetCompatibleKafkaVersionsRequest.Builder avoiding
the need to create one manually via GetCompatibleKafkaVersionsRequest.builder()
getCompatibleKafkaVersionsRequest - A Consumer that will call methods on GetCompatibleKafkaVersionsRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
nThe request is not authorized. The provided credentials couldn't be validated.
nThere was an unexpected internal server error. Retrying your request might resolve the issue.
nAccess forbidden. Check your credentials and then retry your request.
nThe resource could not be found due to incorrect input. Correct the input, then retry the request.
n503 response
n429 response
ndefault CompletableFuture<ListClusterOperationsResponse> listClusterOperations(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListClusterOperationsResponse> listClusterOperations(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
This is a convenience which creates an instance of the ListClusterOperationsRequest.Builder avoiding the
need to create one manually via ListClusterOperationsRequest.builder()
listClusterOperationsRequest - A Consumer that will call methods on ListClusterOperationsRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClusterOperationsPublisher listClusterOperationsPaginator(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
This is a variant of
listClusterOperations(software.amazon.awssdk.services.kafka.model.ListClusterOperationsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsPublisher publisher = client.listClusterOperationsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsPublisher publisher = client.listClusterOperationsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClusterOperationsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClusterOperationsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClusterOperations(software.amazon.awssdk.services.kafka.model.ListClusterOperationsRequest)
operation.
listClusterOperationsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClusterOperationsPublisher listClusterOperationsPaginator(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
This is a variant of
listClusterOperations(software.amazon.awssdk.services.kafka.model.ListClusterOperationsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsPublisher publisher = client.listClusterOperationsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsPublisher publisher = client.listClusterOperationsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClusterOperationsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClusterOperationsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClusterOperations(software.amazon.awssdk.services.kafka.model.ListClusterOperationsRequest)
operation.
This is a convenience which creates an instance of the ListClusterOperationsRequest.Builder avoiding the
need to create one manually via ListClusterOperationsRequest.builder()
listClusterOperationsRequest - A Consumer that will call methods on ListClusterOperationsRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListClustersResponse> listClusters(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
listClustersRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListClustersResponse> listClusters(Consumer<ListClustersRequest.Builder> listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
This is a convenience which creates an instance of the ListClustersRequest.Builder avoiding the need to
create one manually via ListClustersRequest.builder()
listClustersRequest - A Consumer that will call methods on ListClustersRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListClustersResponse> listClusters()
Returns a list of all the MSK clusters in the current Region.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClustersPublisher listClustersPaginator()
Returns a list of all the MSK clusters in the current Region.
This is a variant of listClusters(software.amazon.awssdk.services.kafka.model.ListClustersRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClustersPublisher publisher = client.listClustersPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClustersPublisher publisher = client.listClustersPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClustersResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClustersResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClusters(software.amazon.awssdk.services.kafka.model.ListClustersRequest) operation.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClustersPublisher listClustersPaginator(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
This is a variant of listClusters(software.amazon.awssdk.services.kafka.model.ListClustersRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClustersPublisher publisher = client.listClustersPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClustersPublisher publisher = client.listClustersPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClustersResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClustersResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClusters(software.amazon.awssdk.services.kafka.model.ListClustersRequest) operation.
listClustersRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClustersPublisher listClustersPaginator(Consumer<ListClustersRequest.Builder> listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
This is a variant of listClusters(software.amazon.awssdk.services.kafka.model.ListClustersRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClustersPublisher publisher = client.listClustersPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClustersPublisher publisher = client.listClustersPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClustersResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClustersResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClusters(software.amazon.awssdk.services.kafka.model.ListClustersRequest) operation.
This is a convenience which creates an instance of the ListClustersRequest.Builder avoiding the need to
create one manually via ListClustersRequest.builder()
listClustersRequest - A Consumer that will call methods on ListClustersRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListClustersV2Response> listClustersV2(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
listClustersV2Request - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListClustersV2Response> listClustersV2(Consumer<ListClustersV2Request.Builder> listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
This is a convenience which creates an instance of the ListClustersV2Request.Builder avoiding the need to
create one manually via ListClustersV2Request.builder()
listClustersV2Request - A Consumer that will call methods on ListClustersV2Request.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClustersV2Publisher listClustersV2Paginator(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
This is a variant of listClustersV2(software.amazon.awssdk.services.kafka.model.ListClustersV2Request)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Publisher publisher = client.listClustersV2Paginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Publisher publisher = client.listClustersV2Paginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClustersV2Response>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClustersV2Response response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClustersV2(software.amazon.awssdk.services.kafka.model.ListClustersV2Request) operation.
listClustersV2Request - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default ListClustersV2Publisher listClustersV2Paginator(Consumer<ListClustersV2Request.Builder> listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
This is a variant of listClustersV2(software.amazon.awssdk.services.kafka.model.ListClustersV2Request)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Publisher publisher = client.listClustersV2Paginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Publisher publisher = client.listClustersV2Paginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListClustersV2Response>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListClustersV2Response response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listClustersV2(software.amazon.awssdk.services.kafka.model.ListClustersV2Request) operation.
This is a convenience which creates an instance of the ListClustersV2Request.Builder avoiding the need to
create one manually via ListClustersV2Request.builder()
listClustersV2Request - A Consumer that will call methods on ListClustersV2Request.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
The request is not authorized. The provided credentials couldn't be validated.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListConfigurationRevisionsResponse> listConfigurationRevisions(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
listConfigurationRevisionsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<ListConfigurationRevisionsResponse> listConfigurationRevisions(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
This is a convenience which creates an instance of the ListConfigurationRevisionsRequest.Builder avoiding
the need to create one manually via ListConfigurationRevisionsRequest.builder()
listConfigurationRevisionsRequest - A Consumer that will call methods on ListConfigurationRevisionsRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default ListConfigurationRevisionsPublisher listConfigurationRevisionsPaginator(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
This is a variant of
listConfigurationRevisions(software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsPublisher publisher = client.listConfigurationRevisionsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsPublisher publisher = client.listConfigurationRevisionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listConfigurationRevisions(software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsRequest)
operation.
listConfigurationRevisionsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default ListConfigurationRevisionsPublisher listConfigurationRevisionsPaginator(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
This is a variant of
listConfigurationRevisions(software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsPublisher publisher = client.listConfigurationRevisionsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsPublisher publisher = client.listConfigurationRevisionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listConfigurationRevisions(software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsRequest)
operation.
This is a convenience which creates an instance of the ListConfigurationRevisionsRequest.Builder avoiding
the need to create one manually via ListConfigurationRevisionsRequest.builder()
listConfigurationRevisionsRequest - A Consumer that will call methods on ListConfigurationRevisionsRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<ListConfigurationsResponse> listConfigurations(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
listConfigurationsRequest - 503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListConfigurationsResponse> listConfigurations(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
This is a convenience which creates an instance of the ListConfigurationsRequest.Builder avoiding the
need to create one manually via ListConfigurationsRequest.builder()
listConfigurationsRequest - A Consumer that will call methods on ListConfigurationsRequest.Builder to create a
request.503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default ListConfigurationsPublisher listConfigurationsPaginator(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
This is a variant of
listConfigurations(software.amazon.awssdk.services.kafka.model.ListConfigurationsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsPublisher publisher = client.listConfigurationsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsPublisher publisher = client.listConfigurationsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListConfigurationsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListConfigurationsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listConfigurations(software.amazon.awssdk.services.kafka.model.ListConfigurationsRequest) operation.
listConfigurationsRequest - 503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default ListConfigurationsPublisher listConfigurationsPaginator(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
This is a variant of
listConfigurations(software.amazon.awssdk.services.kafka.model.ListConfigurationsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsPublisher publisher = client.listConfigurationsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsPublisher publisher = client.listConfigurationsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListConfigurationsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListConfigurationsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listConfigurations(software.amazon.awssdk.services.kafka.model.ListConfigurationsRequest) operation.
This is a convenience which creates an instance of the ListConfigurationsRequest.Builder avoiding the
need to create one manually via ListConfigurationsRequest.builder()
listConfigurationsRequest - A Consumer that will call methods on ListConfigurationsRequest.Builder to create a
request.503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListKafkaVersionsResponse> listKafkaVersions(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
listKafkaVersionsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListKafkaVersionsResponse> listKafkaVersions(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
This is a convenience which creates an instance of the ListKafkaVersionsRequest.Builder avoiding the need
to create one manually via ListKafkaVersionsRequest.builder()
listKafkaVersionsRequest - A Consumer that will call methods on ListKafkaVersionsRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default ListKafkaVersionsPublisher listKafkaVersionsPaginator(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
This is a variant of
listKafkaVersions(software.amazon.awssdk.services.kafka.model.ListKafkaVersionsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsPublisher publisher = client.listKafkaVersionsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsPublisher publisher = client.listKafkaVersionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListKafkaVersionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListKafkaVersionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listKafkaVersions(software.amazon.awssdk.services.kafka.model.ListKafkaVersionsRequest) operation.
listKafkaVersionsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default ListKafkaVersionsPublisher listKafkaVersionsPaginator(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
This is a variant of
listKafkaVersions(software.amazon.awssdk.services.kafka.model.ListKafkaVersionsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsPublisher publisher = client.listKafkaVersionsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsPublisher publisher = client.listKafkaVersionsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListKafkaVersionsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListKafkaVersionsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listKafkaVersions(software.amazon.awssdk.services.kafka.model.ListKafkaVersionsRequest) operation.
This is a convenience which creates an instance of the ListKafkaVersionsRequest.Builder avoiding the need
to create one manually via ListKafkaVersionsRequest.builder()
listKafkaVersionsRequest - A Consumer that will call methods on ListKafkaVersionsRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListNodesResponse> listNodes(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
listNodesRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListNodesResponse> listNodes(Consumer<ListNodesRequest.Builder> listNodesRequest)
Returns a list of the broker nodes in the cluster.
This is a convenience which creates an instance of the ListNodesRequest.Builder avoiding the need to
create one manually via ListNodesRequest.builder()
listNodesRequest - A Consumer that will call methods on ListNodesRequest.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default ListNodesPublisher listNodesPaginator(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
This is a variant of listNodes(software.amazon.awssdk.services.kafka.model.ListNodesRequest) operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListNodesPublisher publisher = client.listNodesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListNodesPublisher publisher = client.listNodesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListNodesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListNodesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listNodes(software.amazon.awssdk.services.kafka.model.ListNodesRequest) operation.
listNodesRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default ListNodesPublisher listNodesPaginator(Consumer<ListNodesRequest.Builder> listNodesRequest)
Returns a list of the broker nodes in the cluster.
This is a variant of listNodes(software.amazon.awssdk.services.kafka.model.ListNodesRequest) operation.
The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListNodesPublisher publisher = client.listNodesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListNodesPublisher publisher = client.listNodesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListNodesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListNodesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listNodes(software.amazon.awssdk.services.kafka.model.ListNodesRequest) operation.
This is a convenience which creates an instance of the ListNodesRequest.Builder avoiding the need to
create one manually via ListNodesRequest.builder()
listNodesRequest - A Consumer that will call methods on ListNodesRequest.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<ListScramSecretsResponse> listScramSecrets(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecretsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<ListScramSecretsResponse> listScramSecrets(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
This is a convenience which creates an instance of the ListScramSecretsRequest.Builder avoiding the need
to create one manually via ListScramSecretsRequest.builder()
listScramSecretsRequest - A Consumer that will call methods on ListScramSecretsRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default ListScramSecretsPublisher listScramSecretsPaginator(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
This is a variant of
listScramSecrets(software.amazon.awssdk.services.kafka.model.ListScramSecretsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsPublisher publisher = client.listScramSecretsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsPublisher publisher = client.listScramSecretsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListScramSecretsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListScramSecretsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listScramSecrets(software.amazon.awssdk.services.kafka.model.ListScramSecretsRequest) operation.
listScramSecretsRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default ListScramSecretsPublisher listScramSecretsPaginator(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
This is a variant of
listScramSecrets(software.amazon.awssdk.services.kafka.model.ListScramSecretsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsPublisher publisher = client.listScramSecretsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsPublisher publisher = client.listScramSecretsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.kafka.model.ListScramSecretsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.kafka.model.ListScramSecretsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listScramSecrets(software.amazon.awssdk.services.kafka.model.ListScramSecretsRequest) operation.
This is a convenience which creates an instance of the ListScramSecretsRequest.Builder avoiding the need
to create one manually via ListScramSecretsRequest.builder()
listScramSecretsRequest - A Consumer that will call methods on ListScramSecretsRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
listTagsForResourceRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder avoiding the
need to create one manually via ListTagsForResourceRequest.builder()
listTagsForResourceRequest - A Consumer that will call methods on ListTagsForResourceRequest.Builder to create a
request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
default CompletableFuture<RebootBrokerResponse> rebootBroker(RebootBrokerRequest rebootBrokerRequest)
rebootBrokerRequest - Reboots a node.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<RebootBrokerResponse> rebootBroker(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest)
This is a convenience which creates an instance of the RebootBrokerRequest.Builder avoiding the need to
create one manually via RebootBrokerRequest.builder()
rebootBrokerRequest - A Consumer that will call methods on RebootBrokerRequest.Builder to create a request.
Reboots a node.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<TagResourceResponse> tagResource(TagResourceRequest tagResourceRequest)
Adds tags to the specified MSK resource.
tagResourceRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
default CompletableFuture<TagResourceResponse> tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)
Adds tags to the specified MSK resource.
This is a convenience which creates an instance of the TagResourceRequest.Builder avoiding the need to
create one manually via TagResourceRequest.builder()
tagResourceRequest - A Consumer that will call methods on TagResourceRequest.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
default CompletableFuture<UntagResourceResponse> untagResource(UntagResourceRequest untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
untagResourceRequest - The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
default CompletableFuture<UntagResourceResponse> untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
This is a convenience which creates an instance of the UntagResourceRequest.Builder avoiding the need to
create one manually via UntagResourceRequest.builder()
untagResourceRequest - A Consumer that will call methods on UntagResourceRequest.Builder to create a request.The resource could not be found due to incorrect input. Correct the input, then retry the request.
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
There was an unexpected internal server error. Retrying your request might resolve the issue.
default CompletableFuture<UpdateBrokerCountResponse> updateBrokerCount(UpdateBrokerCountRequest updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
updateBrokerCountRequest - 503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<UpdateBrokerCountResponse> updateBrokerCount(Consumer<UpdateBrokerCountRequest.Builder> updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
This is a convenience which creates an instance of the UpdateBrokerCountRequest.Builder avoiding the need
to create one manually via UpdateBrokerCountRequest.builder()
updateBrokerCountRequest - A Consumer that will call methods on UpdateBrokerCountRequest.Builder to create a request.503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<UpdateBrokerStorageResponse> updateBrokerStorage(UpdateBrokerStorageRequest updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
updateBrokerStorageRequest - 503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<UpdateBrokerStorageResponse> updateBrokerStorage(Consumer<UpdateBrokerStorageRequest.Builder> updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
This is a convenience which creates an instance of the UpdateBrokerStorageRequest.Builder avoiding the
need to create one manually via UpdateBrokerStorageRequest.builder()
updateBrokerStorageRequest - A Consumer that will call methods on UpdateBrokerStorageRequest.Builder to create a
request.503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<UpdateBrokerTypeResponse> updateBrokerType(UpdateBrokerTypeRequest updateBrokerTypeRequest)
Updates EC2 instance type.
updateBrokerTypeRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<UpdateBrokerTypeResponse> updateBrokerType(Consumer<UpdateBrokerTypeRequest.Builder> updateBrokerTypeRequest)
Updates EC2 instance type.
This is a convenience which creates an instance of the UpdateBrokerTypeRequest.Builder avoiding the need
to create one manually via UpdateBrokerTypeRequest.builder()
updateBrokerTypeRequest - A Consumer that will call methods on UpdateBrokerTypeRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<UpdateClusterConfigurationResponse> updateClusterConfiguration(UpdateClusterConfigurationRequest updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
updateClusterConfigurationRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<UpdateClusterConfigurationResponse> updateClusterConfiguration(Consumer<UpdateClusterConfigurationRequest.Builder> updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
This is a convenience which creates an instance of the UpdateClusterConfigurationRequest.Builder avoiding
the need to create one manually via UpdateClusterConfigurationRequest.builder()
updateClusterConfigurationRequest - A Consumer that will call methods on UpdateClusterConfigurationRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<UpdateClusterKafkaVersionResponse> updateClusterKafkaVersion(UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersionRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<UpdateClusterKafkaVersionResponse> updateClusterKafkaVersion(Consumer<UpdateClusterKafkaVersionRequest.Builder> updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
This is a convenience which creates an instance of the UpdateClusterKafkaVersionRequest.Builder avoiding
the need to create one manually via UpdateClusterKafkaVersionRequest.builder()
updateClusterKafkaVersionRequest - A Consumer that will call methods on UpdateClusterKafkaVersionRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
429 response
default CompletableFuture<UpdateConfigurationResponse> updateConfiguration(UpdateConfigurationRequest updateConfigurationRequest)
Updates an MSK configuration.
updateConfigurationRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<UpdateConfigurationResponse> updateConfiguration(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest)
Updates an MSK configuration.
This is a convenience which creates an instance of the UpdateConfigurationRequest.Builder avoiding the
need to create one manually via UpdateConfigurationRequest.builder()
updateConfigurationRequest - A Consumer that will call methods on UpdateConfigurationRequest.Builder to create a
request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<UpdateConnectivityResponse> updateConnectivity(UpdateConnectivityRequest updateConnectivityRequest)
Updates the cluster's connectivity configuration.
updateConnectivityRequest - Request body for UpdateConnectivity.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<UpdateConnectivityResponse> updateConnectivity(Consumer<UpdateConnectivityRequest.Builder> updateConnectivityRequest)
Updates the cluster's connectivity configuration.
This is a convenience which creates an instance of the UpdateConnectivityRequest.Builder avoiding the
need to create one manually via UpdateConnectivityRequest.builder()
updateConnectivityRequest - A Consumer that will call methods on UpdateConnectivityRequest.Builder to create a
request. Request body for UpdateConnectivity.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
503 response
default CompletableFuture<UpdateMonitoringResponse> updateMonitoring(UpdateMonitoringRequest updateMonitoringRequest)
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.
updateMonitoringRequest - Request body for UpdateMonitoring.503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<UpdateMonitoringResponse> updateMonitoring(Consumer<UpdateMonitoringRequest.Builder> updateMonitoringRequest)
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.
This is a convenience which creates an instance of the UpdateMonitoringRequest.Builder avoiding the need
to create one manually via UpdateMonitoringRequest.builder()
updateMonitoringRequest - A Consumer that will call methods on UpdateMonitoringRequest.Builder to create a request.
Request body for UpdateMonitoring.503 response
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
default CompletableFuture<UpdateSecurityResponse> updateSecurity(UpdateSecurityRequest updateSecurityRequest)
Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurityRequest - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
The service cannot complete the request.
The request throughput limit was exceeded.
default CompletableFuture<UpdateSecurityResponse> updateSecurity(Consumer<UpdateSecurityRequest.Builder> updateSecurityRequest)
Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
This is a convenience which creates an instance of the UpdateSecurityRequest.Builder avoiding the need to
create one manually via UpdateSecurityRequest.builder()
updateSecurityRequest - A Consumer that will call methods on UpdateSecurityRequest.Builder to create a request.The request isn't valid because the input is incorrect. Correct your input and then submit it again.
The request is not authorized. The provided credentials couldn't be validated.
There was an unexpected internal server error. Retrying your request might resolve the issue.
Access forbidden. Check your credentials and then retry your request.
The resource could not be found due to incorrect input. Correct the input, then retry the request.
The service cannot complete the request.
The request throughput limit was exceeded.
Copyright © 2022. All rights reserved.