@Generated(value="software.amazon.awssdk:codegen") @ThreadSafe public interface KafkaClient 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 BatchAssociateScramSecretResponse |
batchAssociateScramSecret(BatchAssociateScramSecretRequest batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
|
default BatchAssociateScramSecretResponse |
batchAssociateScramSecret(Consumer<BatchAssociateScramSecretRequest.Builder> batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
|
default BatchDisassociateScramSecretResponse |
batchDisassociateScramSecret(BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
|
default BatchDisassociateScramSecretResponse |
batchDisassociateScramSecret(Consumer<BatchDisassociateScramSecretRequest.Builder> batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
|
static KafkaClientBuilder |
builder()
Create a builder that can be used to configure and create a
KafkaClient. |
static KafkaClient |
create()
Create a
KafkaClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider. |
default CreateClusterResponse |
createCluster(Consumer<CreateClusterRequest.Builder> createClusterRequest)
Creates a new MSK cluster.
|
default CreateClusterResponse |
createCluster(CreateClusterRequest createClusterRequest)
Creates a new MSK cluster.
|
default CreateClusterV2Response |
createClusterV2(Consumer<CreateClusterV2Request.Builder> createClusterV2Request)
Creates a new MSK cluster.
|
default CreateClusterV2Response |
createClusterV2(CreateClusterV2Request createClusterV2Request)
Creates a new MSK cluster.
|
default CreateConfigurationResponse |
createConfiguration(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest)
Creates a new MSK configuration.
|
default CreateConfigurationResponse |
createConfiguration(CreateConfigurationRequest createConfigurationRequest)
Creates a new MSK configuration.
|
default DeleteClusterResponse |
deleteCluster(Consumer<DeleteClusterRequest.Builder> deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
|
default DeleteClusterResponse |
deleteCluster(DeleteClusterRequest deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
|
default DeleteConfigurationResponse |
deleteConfiguration(Consumer<DeleteConfigurationRequest.Builder> deleteConfigurationRequest)
Deletes an MSK Configuration.
|
default DeleteConfigurationResponse |
deleteConfiguration(DeleteConfigurationRequest deleteConfigurationRequest)
Deletes an MSK Configuration.
|
default DescribeClusterResponse |
describeCluster(Consumer<DescribeClusterRequest.Builder> describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default DescribeClusterResponse |
describeCluster(DescribeClusterRequest describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default DescribeClusterOperationResponse |
describeClusterOperation(Consumer<DescribeClusterOperationRequest.Builder> describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
|
default DescribeClusterOperationResponse |
describeClusterOperation(DescribeClusterOperationRequest describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
|
default DescribeClusterV2Response |
describeClusterV2(Consumer<DescribeClusterV2Request.Builder> describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default DescribeClusterV2Response |
describeClusterV2(DescribeClusterV2Request describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
default DescribeConfigurationResponse |
describeConfiguration(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest)
Returns a description of this MSK configuration.
|
default DescribeConfigurationResponse |
describeConfiguration(DescribeConfigurationRequest describeConfigurationRequest)
Returns a description of this MSK configuration.
|
default DescribeConfigurationRevisionResponse |
describeConfigurationRevision(Consumer<DescribeConfigurationRevisionRequest.Builder> describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
|
default DescribeConfigurationRevisionResponse |
describeConfigurationRevision(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
|
default GetBootstrapBrokersResponse |
getBootstrapBrokers(Consumer<GetBootstrapBrokersRequest.Builder> getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
|
default GetBootstrapBrokersResponse |
getBootstrapBrokers(GetBootstrapBrokersRequest getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
|
default GetCompatibleKafkaVersionsResponse |
getCompatibleKafkaVersions(Consumer<GetCompatibleKafkaVersionsRequest.Builder> getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
|
default GetCompatibleKafkaVersionsResponse |
getCompatibleKafkaVersions(GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
|
default ListClusterOperationsResponse |
listClusterOperations(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default ListClusterOperationsResponse |
listClusterOperations(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default ListClusterOperationsIterable |
listClusterOperationsPaginator(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default ListClusterOperationsIterable |
listClusterOperationsPaginator(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
default ListClustersResponse |
listClusters()
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersResponse |
listClusters(Consumer<ListClustersRequest.Builder> listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersResponse |
listClusters(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersIterable |
listClustersPaginator()
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersIterable |
listClustersPaginator(Consumer<ListClustersRequest.Builder> listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersIterable |
listClustersPaginator(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersV2Response |
listClustersV2(Consumer<ListClustersV2Request.Builder> listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersV2Response |
listClustersV2(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersV2Iterable |
listClustersV2Paginator(Consumer<ListClustersV2Request.Builder> listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default ListClustersV2Iterable |
listClustersV2Paginator(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
|
default ListConfigurationRevisionsResponse |
listConfigurationRevisions(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationRevisionsResponse |
listConfigurationRevisions(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationRevisionsIterable |
listConfigurationRevisionsPaginator(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationRevisionsIterable |
listConfigurationRevisionsPaginator(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationsResponse |
listConfigurations(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationsResponse |
listConfigurations(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationsIterable |
listConfigurationsPaginator(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListConfigurationsIterable |
listConfigurationsPaginator(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
|
default ListKafkaVersionsResponse |
listKafkaVersions(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default ListKafkaVersionsResponse |
listKafkaVersions(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default ListKafkaVersionsIterable |
listKafkaVersionsPaginator(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default ListKafkaVersionsIterable |
listKafkaVersionsPaginator(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
|
default ListNodesResponse |
listNodes(Consumer<ListNodesRequest.Builder> listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default ListNodesResponse |
listNodes(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default ListNodesIterable |
listNodesPaginator(Consumer<ListNodesRequest.Builder> listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default ListNodesIterable |
listNodesPaginator(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
|
default ListScramSecretsResponse |
listScramSecrets(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default ListScramSecretsResponse |
listScramSecrets(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default ListScramSecretsIterable |
listScramSecretsPaginator(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default ListScramSecretsIterable |
listScramSecretsPaginator(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
default ListTagsForResourceResponse |
listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
|
default ListTagsForResourceResponse |
listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
|
default RebootBrokerResponse |
rebootBroker(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest)
Reboots brokers.
|
default RebootBrokerResponse |
rebootBroker(RebootBrokerRequest rebootBrokerRequest)
Reboots brokers.
|
static ServiceMetadata |
serviceMetadata() |
default TagResourceResponse |
tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)
Adds tags to the specified MSK resource.
|
default TagResourceResponse |
tagResource(TagResourceRequest tagResourceRequest)
Adds tags to the specified MSK resource.
|
default UntagResourceResponse |
untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
|
default UntagResourceResponse |
untagResource(UntagResourceRequest untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
|
default UpdateBrokerCountResponse |
updateBrokerCount(Consumer<UpdateBrokerCountRequest.Builder> updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
|
default UpdateBrokerCountResponse |
updateBrokerCount(UpdateBrokerCountRequest updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
|
default UpdateBrokerStorageResponse |
updateBrokerStorage(Consumer<UpdateBrokerStorageRequest.Builder> updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
|
default UpdateBrokerStorageResponse |
updateBrokerStorage(UpdateBrokerStorageRequest updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
|
default UpdateBrokerTypeResponse |
updateBrokerType(Consumer<UpdateBrokerTypeRequest.Builder> updateBrokerTypeRequest)
Updates EC2 instance type.
|
default UpdateBrokerTypeResponse |
updateBrokerType(UpdateBrokerTypeRequest updateBrokerTypeRequest)
Updates EC2 instance type.
|
default UpdateClusterConfigurationResponse |
updateClusterConfiguration(Consumer<UpdateClusterConfigurationRequest.Builder> updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
|
default UpdateClusterConfigurationResponse |
updateClusterConfiguration(UpdateClusterConfigurationRequest updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
|
default UpdateClusterKafkaVersionResponse |
updateClusterKafkaVersion(Consumer<UpdateClusterKafkaVersionRequest.Builder> updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
|
default UpdateClusterKafkaVersionResponse |
updateClusterKafkaVersion(UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
|
default UpdateConfigurationResponse |
updateConfiguration(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest)
Updates an MSK configuration.
|
default UpdateConfigurationResponse |
updateConfiguration(UpdateConfigurationRequest updateConfigurationRequest)
Updates an MSK configuration.
|
default UpdateConnectivityResponse |
updateConnectivity(Consumer<UpdateConnectivityRequest.Builder> updateConnectivityRequest)
Updates the cluster's connectivity configuration.
|
default UpdateConnectivityResponse |
updateConnectivity(UpdateConnectivityRequest updateConnectivityRequest)
Updates the cluster's connectivity configuration.
|
default UpdateMonitoringResponse |
updateMonitoring(Consumer<UpdateMonitoringRequest.Builder> updateMonitoringRequest)
Updates the monitoring settings for the cluster.
|
default UpdateMonitoringResponse |
updateMonitoring(UpdateMonitoringRequest updateMonitoringRequest)
Updates the monitoring settings for the cluster.
|
default UpdateSecurityResponse |
updateSecurity(Consumer<UpdateSecurityRequest.Builder> updateSecurityRequest)
Updates the security settings for the cluster.
|
default UpdateSecurityResponse |
updateSecurity(UpdateSecurityRequest updateSecurityRequest)
Updates the security settings for the cluster.
|
serviceNameclosestatic final String SERVICE_NAME
static final String SERVICE_METADATA_ID
ServiceMetadataProvider.static KafkaClient create()
KafkaClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider.static KafkaClientBuilder builder()
KafkaClient.default BatchAssociateScramSecretResponse batchAssociateScramSecret(BatchAssociateScramSecretRequest batchAssociateScramSecretRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecretRequest - Associates sasl scram secrets to cluster.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault BatchAssociateScramSecretResponse batchAssociateScramSecret(Consumer<BatchAssociateScramSecretRequest.Builder> batchAssociateScramSecretRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault BatchDisassociateScramSecretResponse batchDisassociateScramSecret(BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecretRequest - Disassociates sasl scram secrets to cluster.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault BatchDisassociateScramSecretResponse batchDisassociateScramSecret(Consumer<BatchDisassociateScramSecretRequest.Builder> batchDisassociateScramSecretRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault CreateClusterResponse createCluster(CreateClusterRequest createClusterRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, ServiceUnavailableException, TooManyRequestsException, ConflictException, AwsServiceException, SdkClientException, KafkaException
Creates a new MSK cluster.
createClusterRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
ConflictException - This cluster name already exists. Retry your request using another name.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault CreateClusterResponse createCluster(Consumer<CreateClusterRequest.Builder> createClusterRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, ServiceUnavailableException, TooManyRequestsException, ConflictException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
ConflictException - This cluster name already exists. Retry your request using another name.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault CreateClusterV2Response createClusterV2(CreateClusterV2Request createClusterV2Request) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, ServiceUnavailableException, TooManyRequestsException, ConflictException, AwsServiceException, SdkClientException, KafkaException
Creates a new MSK cluster.
createClusterV2Request - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
ConflictException - This cluster name already exists. Retry your request using another name.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault CreateClusterV2Response createClusterV2(Consumer<CreateClusterV2Request.Builder> createClusterV2Request) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, ServiceUnavailableException, TooManyRequestsException, ConflictException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
ConflictException - This cluster name already exists. Retry your request using another name.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault CreateConfigurationResponse createConfiguration(CreateConfigurationRequest createConfigurationRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, ServiceUnavailableException, TooManyRequestsException, ConflictException, AwsServiceException, SdkClientException, KafkaException
Creates a new MSK configuration.
createConfigurationRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
ConflictException - This cluster name already exists. Retry your request using another name.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault CreateConfigurationResponse createConfiguration(Consumer<CreateConfigurationRequest.Builder> createConfigurationRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, ServiceUnavailableException, TooManyRequestsException, ConflictException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
ConflictException - This cluster name already exists. Retry your request using another name.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DeleteClusterResponse deleteCluster(DeleteClusterRequest deleteClusterRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteClusterRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DeleteClusterResponse deleteCluster(Consumer<DeleteClusterRequest.Builder> deleteClusterRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DeleteConfigurationResponse deleteConfiguration(DeleteConfigurationRequest deleteConfigurationRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Deletes an MSK Configuration.
deleteConfigurationRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DeleteConfigurationResponse deleteConfiguration(Consumer<DeleteConfigurationRequest.Builder> deleteConfigurationRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeClusterResponse describeCluster(DescribeClusterRequest describeClusterRequest) throws NotFoundException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeClusterResponse describeCluster(Consumer<DescribeClusterRequest.Builder> describeClusterRequest) throws NotFoundException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeClusterOperationResponse describeClusterOperation(DescribeClusterOperationRequest describeClusterOperationRequest) throws NotFoundException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeClusterOperationResponse describeClusterOperation(Consumer<DescribeClusterOperationRequest.Builder> describeClusterOperationRequest) throws NotFoundException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeClusterV2Response describeClusterV2(DescribeClusterV2Request describeClusterV2Request) throws NotFoundException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2Request - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeClusterV2Response describeClusterV2(Consumer<DescribeClusterV2Request.Builder> describeClusterV2Request) throws NotFoundException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeConfigurationResponse describeConfiguration(DescribeConfigurationRequest describeConfigurationRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
Returns a description of this MSK configuration.
describeConfigurationRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeConfigurationResponse describeConfiguration(Consumer<DescribeConfigurationRequest.Builder> describeConfigurationRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeConfigurationRevisionResponse describeConfigurationRevision(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
Returns a description of this revision of the configuration.
describeConfigurationRevisionRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault DescribeConfigurationRevisionResponse describeConfigurationRevision(Consumer<DescribeConfigurationRevisionRequest.Builder> describeConfigurationRevisionRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault GetBootstrapBrokersResponse getBootstrapBrokers(GetBootstrapBrokersRequest getBootstrapBrokersRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
A list of brokers that a client application can use to bootstrap.
getBootstrapBrokersRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ConflictException - This cluster name already exists. Retry your request using another name.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault GetBootstrapBrokersResponse getBootstrapBrokers(Consumer<GetBootstrapBrokersRequest.Builder> getBootstrapBrokersRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ConflictException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ConflictException - This cluster name already exists. Retry your request using another name.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault GetCompatibleKafkaVersionsResponse getCompatibleKafkaVersions(GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersionsRequest - BadRequestException - n
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
nUnauthorizedException - n
The request is not authorized. The provided credentials couldn't be validated.
nInternalServerErrorException - n
There was an unexpected internal server error. Retrying your request might resolve the issue.
nForbiddenException - n
Access forbidden. Check your credentials and then retry your request.
nNotFoundException - n
The resource could not be found due to incorrect input. Correct the input, then retry the request.
nServiceUnavailableException - n
503 response
nTooManyRequestsException - n
429 response
nSdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault GetCompatibleKafkaVersionsResponse getCompatibleKafkaVersions(Consumer<GetCompatibleKafkaVersionsRequest.Builder> getCompatibleKafkaVersionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - n
The request isn't valid because the input is incorrect. Correct your input and then submit it again.
nUnauthorizedException - n
The request is not authorized. The provided credentials couldn't be validated.
nInternalServerErrorException - n
There was an unexpected internal server error. Retrying your request might resolve the issue.
nForbiddenException - n
Access forbidden. Check your credentials and then retry your request.
nNotFoundException - n
The resource could not be found due to incorrect input. Correct the input, then retry the request.
nServiceUnavailableException - n
503 response
nTooManyRequestsException - n
429 response
nSdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClusterOperationsResponse listClusterOperations(ListClusterOperationsRequest listClusterOperationsRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClusterOperationsResponse listClusterOperations(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClusterOperationsIterable listClusterOperationsPaginator(ListClusterOperationsRequest listClusterOperationsRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsIterable responses = client.listClusterOperationsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsIterable responses = client
.listClusterOperationsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClusterOperationsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsIterable responses = client.listClusterOperationsPaginator(request);
responses.iterator().forEachRemaining(....);
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 - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClusterOperationsIterable listClusterOperationsPaginator(Consumer<ListClusterOperationsRequest.Builder> listClusterOperationsRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsIterable responses = client.listClusterOperationsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsIterable responses = client
.listClusterOperationsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClusterOperationsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClusterOperationsIterable responses = client.listClusterOperationsPaginator(request);
responses.iterator().forEachRemaining(....);
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersResponse listClusters() throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of all the MSK clusters in the current Region.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptionlistClusters(ListClustersRequest),
AWS API
Documentationdefault ListClustersResponse listClusters(ListClustersRequest listClustersRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of all the MSK clusters in the current Region.
listClustersRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersResponse listClusters(Consumer<ListClustersRequest.Builder> listClustersRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersIterable listClustersPaginator() throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClustersResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
responses.iterator().forEachRemaining(....);
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.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptionlistClustersPaginator(ListClustersRequest),
AWS API
Documentationdefault ListClustersIterable listClustersPaginator(ListClustersRequest listClustersRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClustersResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
responses.iterator().forEachRemaining(....);
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 - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersIterable listClustersPaginator(Consumer<ListClustersRequest.Builder> listClustersRequest) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClustersResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClustersIterable responses = client.listClustersPaginator(request);
responses.iterator().forEachRemaining(....);
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersV2Response listClustersV2(ListClustersV2Request listClustersV2Request) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of all the MSK clusters in the current Region.
listClustersV2Request - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersV2Response listClustersV2(Consumer<ListClustersV2Request.Builder> listClustersV2Request) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersV2Iterable listClustersV2Paginator(ListClustersV2Request listClustersV2Request) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Iterable responses = client.listClustersV2Paginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Iterable responses = client.listClustersV2Paginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClustersV2Response response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Iterable responses = client.listClustersV2Paginator(request);
responses.iterator().forEachRemaining(....);
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 - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListClustersV2Iterable listClustersV2Paginator(Consumer<ListClustersV2Request.Builder> listClustersV2Request) throws BadRequestException, InternalServerErrorException, UnauthorizedException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Iterable responses = client.listClustersV2Paginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Iterable responses = client.listClustersV2Paginator(request);
for (software.amazon.awssdk.services.kafka.model.ListClustersV2Response response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListClustersV2Iterable responses = client.listClustersV2Paginator(request);
responses.iterator().forEachRemaining(....);
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationRevisionsResponse listConfigurationRevisions(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
Returns a list of all the MSK configurations in this Region.
listConfigurationRevisionsRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationRevisionsResponse listConfigurationRevisions(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationRevisionsIterable listConfigurationRevisionsPaginator(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsIterable responses = client.listConfigurationRevisionsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsIterable responses = client
.listConfigurationRevisionsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsIterable responses = client.listConfigurationRevisionsPaginator(request);
responses.iterator().forEachRemaining(....);
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 - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationRevisionsIterable listConfigurationRevisionsPaginator(Consumer<ListConfigurationRevisionsRequest.Builder> listConfigurationRevisionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will
internally handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsIterable responses = client.listConfigurationRevisionsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsIterable responses = client
.listConfigurationRevisionsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListConfigurationRevisionsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListConfigurationRevisionsIterable responses = client.listConfigurationRevisionsPaginator(request);
responses.iterator().forEachRemaining(....);
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationsResponse listConfigurations(ListConfigurationsRequest listConfigurationsRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of all the MSK configurations in this Region.
listConfigurationsRequest - ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationsResponse listConfigurations(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationsIterable listConfigurationsPaginator(ListConfigurationsRequest listConfigurationsRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally handle
making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsIterable responses = client.listConfigurationsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsIterable responses = client
.listConfigurationsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListConfigurationsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsIterable responses = client.listConfigurationsPaginator(request);
responses.iterator().forEachRemaining(....);
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 - ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListConfigurationsIterable listConfigurationsPaginator(Consumer<ListConfigurationsRequest.Builder> listConfigurationsRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally handle
making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsIterable responses = client.listConfigurationsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsIterable responses = client
.listConfigurationsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListConfigurationsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListConfigurationsIterable responses = client.listConfigurationsPaginator(request);
responses.iterator().forEachRemaining(....);
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.ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListKafkaVersionsResponse listKafkaVersions(ListKafkaVersionsRequest listKafkaVersionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of Apache Kafka versions.
listKafkaVersionsRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListKafkaVersionsResponse listKafkaVersions(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListKafkaVersionsIterable listKafkaVersionsPaginator(ListKafkaVersionsRequest listKafkaVersionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally handle
making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsIterable responses = client.listKafkaVersionsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsIterable responses = client
.listKafkaVersionsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListKafkaVersionsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsIterable responses = client.listKafkaVersionsPaginator(request);
responses.iterator().forEachRemaining(....);
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 - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListKafkaVersionsIterable listKafkaVersionsPaginator(Consumer<ListKafkaVersionsRequest.Builder> listKafkaVersionsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally handle
making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsIterable responses = client.listKafkaVersionsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsIterable responses = client
.listKafkaVersionsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListKafkaVersionsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListKafkaVersionsIterable responses = client.listKafkaVersionsPaginator(request);
responses.iterator().forEachRemaining(....);
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListNodesResponse listNodes(ListNodesRequest listNodesRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Returns a list of the broker nodes in the cluster.
listNodesRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListNodesResponse listNodes(Consumer<ListNodesRequest.Builder> listNodesRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListNodesIterable listNodesPaginator(ListNodesRequest listNodesRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally
handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListNodesIterable responses = client.listNodesPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListNodesIterable responses = client.listNodesPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListNodesResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListNodesIterable responses = client.listNodesPaginator(request);
responses.iterator().forEachRemaining(....);
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 - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListNodesIterable listNodesPaginator(Consumer<ListNodesRequest.Builder> listNodesRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally
handle making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListNodesIterable responses = client.listNodesPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListNodesIterable responses = client.listNodesPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListNodesResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListNodesIterable responses = client.listNodesPaginator(request);
responses.iterator().forEachRemaining(....);
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListScramSecretsResponse listScramSecrets(ListScramSecretsRequest listScramSecretsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecretsRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListScramSecretsResponse listScramSecrets(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListScramSecretsIterable listScramSecretsPaginator(ListScramSecretsRequest listScramSecretsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally handle
making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsIterable responses = client.listScramSecretsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsIterable responses = client
.listScramSecretsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListScramSecretsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsIterable responses = client.listScramSecretsPaginator(request);
responses.iterator().forEachRemaining(....);
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 - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListScramSecretsIterable listScramSecretsPaginator(Consumer<ListScramSecretsRequest.Builder> listScramSecretsRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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 iterable that can be used to iterate through all the pages. SDK will internally handle
making service calls for you.
When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Stream
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsIterable responses = client.listScramSecretsPaginator(request);
responses.stream().forEach(....);
2) Using For loop
{
@code
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsIterable responses = client
.listScramSecretsPaginator(request);
for (software.amazon.awssdk.services.kafka.model.ListScramSecretsResponse response : responses) {
// do something;
}
}
3) Use iterator directly
software.amazon.awssdk.services.kafka.paginators.ListScramSecretsIterable responses = client.listScramSecretsPaginator(request);
responses.iterator().forEachRemaining(....);
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListTagsForResourceResponse listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, AwsServiceException, SdkClientException, KafkaException
Returns a list of the tags associated with the specified resource.
listTagsForResourceRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault ListTagsForResourceResponse listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault RebootBrokerResponse rebootBroker(RebootBrokerRequest rebootBrokerRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
rebootBrokerRequest - Reboots a node.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault RebootBrokerResponse rebootBroker(Consumer<RebootBrokerRequest.Builder> rebootBrokerRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault TagResourceResponse tagResource(TagResourceRequest tagResourceRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, AwsServiceException, SdkClientException, KafkaException
Adds tags to the specified MSK resource.
tagResourceRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault TagResourceResponse tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UntagResourceResponse untagResource(UntagResourceRequest untagResourceRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, AwsServiceException, SdkClientException, KafkaException
Removes the tags associated with the keys that are provided in the query.
untagResourceRequest - NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UntagResourceResponse untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest) throws NotFoundException, BadRequestException, InternalServerErrorException, AwsServiceException, SdkClientException, KafkaException
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.NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateBrokerCountResponse updateBrokerCount(UpdateBrokerCountRequest updateBrokerCountRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Updates the number of broker nodes in the cluster.
updateBrokerCountRequest - ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateBrokerCountResponse updateBrokerCount(Consumer<UpdateBrokerCountRequest.Builder> updateBrokerCountRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateBrokerStorageResponse updateBrokerStorage(UpdateBrokerStorageRequest updateBrokerStorageRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
Updates the EBS storage associated with MSK brokers.
updateBrokerStorageRequest - ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateBrokerStorageResponse updateBrokerStorage(Consumer<UpdateBrokerStorageRequest.Builder> updateBrokerStorageRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateBrokerTypeResponse updateBrokerType(UpdateBrokerTypeRequest updateBrokerTypeRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Updates EC2 instance type.
updateBrokerTypeRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateBrokerTypeResponse updateBrokerType(Consumer<UpdateBrokerTypeRequest.Builder> updateBrokerTypeRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateClusterConfigurationResponse updateClusterConfiguration(UpdateClusterConfigurationRequest updateClusterConfigurationRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
Updates the cluster with the configuration that is specified in the request body.
updateClusterConfigurationRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateClusterConfigurationResponse updateClusterConfiguration(Consumer<UpdateClusterConfigurationRequest.Builder> updateClusterConfigurationRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateClusterKafkaVersionResponse updateClusterKafkaVersion(UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersionRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateClusterKafkaVersionResponse updateClusterKafkaVersion(Consumer<UpdateClusterKafkaVersionRequest.Builder> updateClusterKafkaVersionRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
TooManyRequestsException - 429 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateConfigurationResponse updateConfiguration(UpdateConfigurationRequest updateConfigurationRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
Updates an MSK configuration.
updateConfigurationRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateConfigurationResponse updateConfiguration(Consumer<UpdateConfigurationRequest.Builder> updateConfigurationRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateConnectivityResponse updateConnectivity(UpdateConnectivityRequest updateConnectivityRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
Updates the cluster's connectivity configuration.
updateConnectivityRequest - Request body for UpdateConnectivity.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateConnectivityResponse updateConnectivity(Consumer<UpdateConnectivityRequest.Builder> updateConnectivityRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - 503 response
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateMonitoringResponse updateMonitoring(UpdateMonitoringRequest updateMonitoringRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateMonitoringResponse updateMonitoring(Consumer<UpdateMonitoringRequest.Builder> updateMonitoringRequest) throws ServiceUnavailableException, BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, AwsServiceException, SdkClientException, KafkaException
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.ServiceUnavailableException - 503 response
BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateSecurityResponse updateSecurity(UpdateSecurityRequest updateSecurityRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurityRequest - BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - The service cannot complete the request.
TooManyRequestsException - The request throughput limit was exceeded.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptiondefault UpdateSecurityResponse updateSecurity(Consumer<UpdateSecurityRequest.Builder> updateSecurityRequest) throws BadRequestException, UnauthorizedException, InternalServerErrorException, ForbiddenException, NotFoundException, ServiceUnavailableException, TooManyRequestsException, AwsServiceException, SdkClientException, KafkaException
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.BadRequestException - The request isn't valid because the input is incorrect. Correct your input and then submit it again.
UnauthorizedException - The request is not authorized. The provided credentials couldn't be validated.
InternalServerErrorException - There was an unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - Access forbidden. Check your credentials and then retry your request.
NotFoundException - The resource could not be found due to incorrect input. Correct the input, then retry the request.
ServiceUnavailableException - The service cannot complete the request.
TooManyRequestsException - The request throughput limit was exceeded.
SdkException - Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
catch all scenarios.SdkClientException - If any client side error occurs such as an IO related failure, failure to get credentials, etc.KafkaException - Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.AwsServiceExceptionstatic ServiceMetadata serviceMetadata()
Copyright © 2022. All rights reserved.