@ThreadSafe @Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class AWSKafkaClient extends AmazonWebServiceClient implements AWSKafka
The operations for managing an Amazon MSK cluster.
LOGGING_AWS_REQUEST_METRIC ENDPOINT_PREFIX | Modifier and Type | Method and Description |
|---|---|
BatchAssociateScramSecretResult |
batchAssociateScramSecret (BatchAssociateScramSecretRequest request)
Associates one or more Scram Secrets with an Amazon MSK cluster.
|
BatchDisassociateScramSecretResult |
batchDisassociateScramSecret (BatchDisassociateScramSecretRequest request)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
|
static AWSKafkaClientBuilder |
builder () |
CreateClusterResult |
createCluster (CreateClusterRequest request)
Creates a new MSK cluster.
|
CreateClusterV2Result |
createClusterV2 (CreateClusterV2Request request)
Creates a new MSK cluster.
|
CreateConfigurationResult |
createConfiguration (CreateConfigurationRequest request)
Creates a new MSK configuration.
|
CreateReplicatorResult |
createReplicator (CreateReplicatorRequest request)
Creates the replicator.
|
CreateVpcConnectionResult |
createVpcConnection (CreateVpcConnectionRequest request)
Creates a new MSK VPC connection.
|
DeleteClusterResult |
deleteCluster (DeleteClusterRequest request)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
|
DeleteClusterPolicyResult |
deleteClusterPolicy (DeleteClusterPolicyRequest request)
Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
|
DeleteConfigurationResult |
deleteConfiguration (DeleteConfigurationRequest request)
Deletes an MSK Configuration.
|
DeleteReplicatorResult |
deleteReplicator (DeleteReplicatorRequest request)
Deletes a replicator.
|
DeleteVpcConnectionResult |
deleteVpcConnection (DeleteVpcConnectionRequest request)
Deletes a MSK VPC connection.
|
DescribeClusterResult |
describeCluster (DescribeClusterRequest request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
DescribeClusterOperationResult |
describeClusterOperation (DescribeClusterOperationRequest request)
Returns a description of the cluster operation specified by the ARN.
|
DescribeClusterOperationV2Result |
describeClusterOperationV2 (DescribeClusterOperationV2Request request)
Returns a description of the cluster operation specified by the ARN.
|
DescribeClusterV2Result |
describeClusterV2 (DescribeClusterV2Request request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
|
DescribeConfigurationResult |
describeConfiguration (DescribeConfigurationRequest request)
Returns a description of this MSK configuration.
|
DescribeConfigurationRevisionResult |
describeConfigurationRevision (DescribeConfigurationRevisionRequest request)
Returns a description of this revision of the configuration.
|
DescribeReplicatorResult |
describeReplicator (DescribeReplicatorRequest request)
Describes a replicator.
|
DescribeVpcConnectionResult |
describeVpcConnection (DescribeVpcConnectionRequest request)
Returns a description of this MSK VPC connection.
|
GetBootstrapBrokersResult |
getBootstrapBrokers (GetBootstrapBrokersRequest request)
A list of brokers that a client application can use to bootstrap.
|
ResponseMetadata |
getCachedResponseMetadata (AmazonWebServiceRequest request)
Returns additional metadata for a previously executed successful, request, typically used for debugging issues
where a service isn't acting as expected.
|
GetClusterPolicyResult |
getClusterPolicy (GetClusterPolicyRequest request)
Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
|
GetCompatibleKafkaVersionsResult |
getCompatibleKafkaVersions (GetCompatibleKafkaVersionsRequest request)
Gets the Apache Kafka versions to which you can update the MSK cluster.
|
ListClientVpcConnectionsResult |
listClientVpcConnections (ListClientVpcConnectionsRequest request)
Returns a list of all the VPC connections in this Region.
|
ListClusterOperationsResult |
listClusterOperations (ListClusterOperationsRequest request)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
ListClusterOperationsV2Result |
listClusterOperationsV2 (ListClusterOperationsV2Request request)
Returns a list of all the operations that have been performed on the specified MSK cluster.
|
ListClustersResult |
listClusters (ListClustersRequest request)
Returns a list of all the MSK clusters in the current Region.
|
ListClustersV2Result |
listClustersV2 (ListClustersV2Request request)
Returns a list of all the MSK clusters in the current Region.
|
ListConfigurationRevisionsResult |
listConfigurationRevisions (ListConfigurationRevisionsRequest request)
Returns a list of all the MSK configurations in this Region.
|
ListConfigurationsResult |
listConfigurations (ListConfigurationsRequest request)
Returns a list of all the MSK configurations in this Region.
|
ListKafkaVersionsResult |
listKafkaVersions (ListKafkaVersionsRequest request)
Returns a list of Apache Kafka versions.
|
ListNodesResult |
listNodes (ListNodesRequest request)
Returns a list of the broker nodes in the cluster.
|
ListReplicatorsResult |
listReplicators (ListReplicatorsRequest request)
Lists the replicators.
|
ListScramSecretsResult |
listScramSecrets (ListScramSecretsRequest request)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
|
ListTagsForResourceResult |
listTagsForResource (ListTagsForResourceRequest request)
Returns a list of the tags associated with the specified resource.
|
ListVpcConnectionsResult |
listVpcConnections (ListVpcConnectionsRequest request)
Returns a list of all the VPC connections in this Region.
|
PutClusterPolicyResult |
putClusterPolicy (PutClusterPolicyRequest request)
Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
|
RebootBrokerResult |
rebootBroker (RebootBrokerRequest request)
Reboots brokers.
|
RejectClientVpcConnectionResult |
rejectClientVpcConnection (RejectClientVpcConnectionRequest request)
Returns empty response.
|
void |
shutdown ()
Shuts down this client object, releasing any resources that might be held
open.
|
TagResourceResult |
tagResource (TagResourceRequest request)
Adds tags to the specified MSK resource.
|
UntagResourceResult |
untagResource (UntagResourceRequest request)
Removes the tags associated with the keys that are provided in the query.
|
UpdateBrokerCountResult |
updateBrokerCount (UpdateBrokerCountRequest request)
Updates the number of broker nodes in the cluster.
|
UpdateBrokerStorageResult |
updateBrokerStorage (UpdateBrokerStorageRequest request)
Updates the EBS storage associated with MSK brokers.
|
UpdateBrokerTypeResult |
updateBrokerType (UpdateBrokerTypeRequest request)
Updates EC2 instance type.
|
UpdateClusterConfigurationResult |
updateClusterConfiguration (UpdateClusterConfigurationRequest request)
Updates the cluster with the configuration that is specified in the request body.
|
UpdateClusterKafkaVersionResult |
updateClusterKafkaVersion (UpdateClusterKafkaVersionRequest request)
Updates the Apache Kafka version for the cluster.
|
UpdateConfigurationResult |
updateConfiguration (UpdateConfigurationRequest request)
Updates an MSK configuration.
|
UpdateConnectivityResult |
updateConnectivity (UpdateConnectivityRequest request)
Updates the cluster's connectivity configuration.
|
UpdateMonitoringResult |
updateMonitoring (UpdateMonitoringRequest request)
Updates the monitoring settings for the cluster.
|
UpdateReplicationInfoResult |
updateReplicationInfo (UpdateReplicationInfoRequest request)
Updates replication info of a replicator.
|
UpdateSecurityResult |
updateSecurity (UpdateSecurityRequest request)
Updates the security settings for the cluster.
|
UpdateStorageResult |
updateStorage (UpdateStorageRequest request)
Updates cluster broker volume size (or) sets cluster storage mode to TIERED.
|
addRequestHandler, addRequestHandler, configureRegion, getClientConfiguration, getEndpointPrefix, getMonitoringListeners, getRequestMetricsCollector, getServiceName, getSignerByURI, getSignerOverride, getSignerRegionOverride, getTimeOffset, makeImmutable, removeRequestHandler, removeRequestHandler, setEndpoint, setEndpoint, setRegion, setServiceNameIntern, setSignerRegionOverride, setTimeOffset, withEndpoint, withRegion, withRegion, withTimeOffset public static AWSKafkaClientBuilder builder()
public BatchAssociateScramSecretResult batchAssociateScramSecret(BatchAssociateScramSecretRequest request)
Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecret in interface AWSKafka 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
public BatchDisassociateScramSecretResult batchDisassociateScramSecret(BatchDisassociateScramSecretRequest request)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecret in interface AWSKafka 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
public CreateClusterResult createCluster(CreateClusterRequest request)
Creates a new MSK cluster.
createCluster in interface AWSKafka 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.
public CreateClusterV2Result createClusterV2(CreateClusterV2Request request)
Creates a new MSK cluster.
createClusterV2 in interface AWSKafka 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.
public CreateConfigurationResult createConfiguration(CreateConfigurationRequest request)
Creates a new MSK configuration.
createConfiguration in interface AWSKafka 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.
public CreateReplicatorResult createReplicator(CreateReplicatorRequest request)
Creates the replicator.
createReplicator in interface AWSKafka createReplicatorRequest - Creates a replicator using the specified configuration.BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.ConflictException - HTTP Status Code 409: Conflict. This replicator name already exists. Retry your request with another
name.public CreateVpcConnectionResult createVpcConnection(CreateVpcConnectionRequest request)
Creates a new MSK VPC connection.
createVpcConnection in interface AWSKafka createVpcConnectionRequest - 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
public DeleteClusterResult deleteCluster(DeleteClusterRequest request)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteCluster in interface AWSKafka 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.
public DeleteClusterPolicyResult deleteClusterPolicy(DeleteClusterPolicyRequest request)
Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
deleteClusterPolicy in interface AWSKafka deleteClusterPolicyRequest - 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.
public DeleteConfigurationResult deleteConfiguration(DeleteConfigurationRequest request)
Deletes an MSK Configuration.
deleteConfiguration in interface AWSKafka 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.
public DeleteReplicatorResult deleteReplicator(DeleteReplicatorRequest request)
Deletes a replicator.
deleteReplicator in interface AWSKafka deleteReplicatorRequest - BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.public DeleteVpcConnectionResult deleteVpcConnection(DeleteVpcConnectionRequest request)
Deletes a MSK VPC connection.
deleteVpcConnection in interface AWSKafka deleteVpcConnectionRequest - 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.
public DescribeClusterResult describeCluster(DescribeClusterRequest request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeCluster in interface AWSKafka 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.
public DescribeClusterOperationResult describeClusterOperation(DescribeClusterOperationRequest request)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperation in interface AWSKafka 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.
public DescribeClusterOperationV2Result describeClusterOperationV2(DescribeClusterOperationV2Request request)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationV2 in interface AWSKafka describeClusterOperationV2Request - BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.
public DescribeClusterV2Result describeClusterV2(DescribeClusterV2Request request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2 in interface AWSKafka 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.
public DescribeConfigurationResult describeConfiguration(DescribeConfigurationRequest request)
Returns a description of this MSK configuration.
describeConfiguration in interface AWSKafka 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
public DescribeConfigurationRevisionResult describeConfigurationRevision(DescribeConfigurationRevisionRequest request)
Returns a description of this revision of the configuration.
describeConfigurationRevision in interface AWSKafka 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
public DescribeReplicatorResult describeReplicator(DescribeReplicatorRequest request)
Describes a replicator.
describeReplicator in interface AWSKafka describeReplicatorRequest - BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.public DescribeVpcConnectionResult describeVpcConnection(DescribeVpcConnectionRequest request)
Returns a description of this MSK VPC connection.
describeVpcConnection in interface AWSKafka describeVpcConnectionRequest - 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
public GetBootstrapBrokersResult getBootstrapBrokers(GetBootstrapBrokersRequest request)
A list of brokers that a client application can use to bootstrap.
getBootstrapBrokers in interface AWSKafka 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.
public GetClusterPolicyResult getClusterPolicy(GetClusterPolicyRequest request)
Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
getClusterPolicy in interface AWSKafka getClusterPolicyRequest - 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.
public GetCompatibleKafkaVersionsResult getCompatibleKafkaVersions(GetCompatibleKafkaVersionsRequest request)
Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersions in interface AWSKafka 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
npublic ListClientVpcConnectionsResult listClientVpcConnections(ListClientVpcConnectionsRequest request)
Returns a list of all the VPC connections in this Region.
listClientVpcConnections in interface AWSKafka listClientVpcConnectionsRequest - 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.
public ListClusterOperationsResult listClusterOperations(ListClusterOperationsRequest request)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperations in interface AWSKafka 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.
public ListClusterOperationsV2Result listClusterOperationsV2(ListClusterOperationsV2Request request)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsV2 in interface AWSKafka listClusterOperationsV2Request - BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.
public ListClustersResult listClusters(ListClustersRequest request)
Returns a list of all the MSK clusters in the current Region.
listClusters in interface AWSKafka 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.
public ListClustersV2Result listClustersV2(ListClustersV2Request request)
Returns a list of all the MSK clusters in the current Region.
listClustersV2 in interface AWSKafka 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.
public ListConfigurationRevisionsResult listConfigurationRevisions(ListConfigurationRevisionsRequest request)
Returns a list of all the MSK configurations in this Region.
listConfigurationRevisions in interface AWSKafka 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
public ListConfigurationsResult listConfigurations(ListConfigurationsRequest request)
Returns a list of all the MSK configurations in this Region.
listConfigurations in interface AWSKafka 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.
public ListKafkaVersionsResult listKafkaVersions(ListKafkaVersionsRequest request)
Returns a list of Apache Kafka versions.
listKafkaVersions in interface AWSKafka 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.
public ListNodesResult listNodes(ListNodesRequest request)
Returns a list of the broker nodes in the cluster.
listNodes in interface AWSKafka 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.
public ListReplicatorsResult listReplicators(ListReplicatorsRequest request)
Lists the replicators.
listReplicators in interface AWSKafka listReplicatorsRequest - BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.public ListScramSecretsResult listScramSecrets(ListScramSecretsRequest request)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecrets in interface AWSKafka 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
public ListTagsForResourceResult listTagsForResource(ListTagsForResourceRequest request)
Returns a list of the tags associated with the specified resource.
listTagsForResource in interface AWSKafka 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.
public ListVpcConnectionsResult listVpcConnections(ListVpcConnectionsRequest request)
Returns a list of all the VPC connections in this Region.
listVpcConnections in interface AWSKafka listVpcConnectionsRequest - 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.
public PutClusterPolicyResult putClusterPolicy(PutClusterPolicyRequest request)
Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
putClusterPolicy in interface AWSKafka putClusterPolicyRequest - 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.
public RebootBrokerResult rebootBroker(RebootBrokerRequest request)
rebootBroker in interface AWSKafka 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
public RejectClientVpcConnectionResult rejectClientVpcConnection(RejectClientVpcConnectionRequest request)
Returns empty response.
rejectClientVpcConnection in interface AWSKafka rejectClientVpcConnectionRequest - 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.
public TagResourceResult tagResource(TagResourceRequest request)
Adds tags to the specified MSK resource.
tagResource in interface AWSKafka 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.
public UntagResourceResult untagResource(UntagResourceRequest request)
Removes the tags associated with the keys that are provided in the query.
untagResource in interface AWSKafka 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.
public UpdateBrokerCountResult updateBrokerCount(UpdateBrokerCountRequest request)
Updates the number of broker nodes in the cluster.
updateBrokerCount in interface AWSKafka 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.
public UpdateBrokerStorageResult updateBrokerStorage(UpdateBrokerStorageRequest request)
Updates the EBS storage associated with MSK brokers.
updateBrokerStorage in interface AWSKafka 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.
public UpdateBrokerTypeResult updateBrokerType(UpdateBrokerTypeRequest request)
Updates EC2 instance type.
updateBrokerType in interface AWSKafka 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
public UpdateClusterConfigurationResult updateClusterConfiguration(UpdateClusterConfigurationRequest request)
Updates the cluster with the configuration that is specified in the request body.
updateClusterConfiguration in interface AWSKafka 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
public UpdateClusterKafkaVersionResult updateClusterKafkaVersion(UpdateClusterKafkaVersionRequest request)
Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersion in interface AWSKafka 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
public UpdateConfigurationResult updateConfiguration(UpdateConfigurationRequest request)
Updates an MSK configuration.
updateConfiguration in interface AWSKafka 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
public UpdateConnectivityResult updateConnectivity(UpdateConnectivityRequest request)
Updates the cluster's connectivity configuration.
updateConnectivity in interface AWSKafka 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
public UpdateMonitoringResult updateMonitoring(UpdateMonitoringRequest request)
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.
updateMonitoring in interface AWSKafka 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.
public UpdateReplicationInfoResult updateReplicationInfo(UpdateReplicationInfoRequest request)
Updates replication info of a replicator.
updateReplicationInfo in interface AWSKafka updateReplicationInfoRequest - Update information relating to replication between a given source and target Kafka cluster.BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.public UpdateSecurityResult updateSecurity(UpdateSecurityRequest request)
Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurity in interface AWSKafka 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.
public UpdateStorageResult updateStorage(UpdateStorageRequest request)
updateStorage in interface AWSKafka updateStorageRequest - Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request)
Response metadata is only cached for a limited period of time, so if you need to access this extra diagnostic information for an executed request, you should use this method to retrieve it as soon as possible after executing the request.
getCachedResponseMetadata in interface AWSKafka request - The originally executed requestpublic void shutdown()
AmazonWebServiceClient shutdown in interface AWSKafka shutdown in class AmazonWebServiceClient