@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public interface AWSKafkaAsync extends AWSKafka
AsyncHandler
can be used to receive notification when
an asynchronous operation completes.
Note: Do not directly implement this interface, new methods are added to it regularly. Extend from
AbstractAWSKafkaAsync
instead.
The operations for managing an Amazon MSK cluster.
ENDPOINT_PREFIX
batchAssociateScramSecret, batchDisassociateScramSecret, createCluster, createClusterV2, createConfiguration, createReplicator, createVpcConnection, deleteCluster, deleteClusterPolicy, deleteConfiguration, deleteReplicator, deleteVpcConnection, describeCluster, describeClusterOperation, describeClusterOperationV2, describeClusterV2, describeConfiguration, describeConfigurationRevision, describeReplicator, describeVpcConnection, getBootstrapBrokers, getCachedResponseMetadata, getClusterPolicy, getCompatibleKafkaVersions, listClientVpcConnections, listClusterOperations, listClusterOperationsV2, listClusters, listClustersV2, listConfigurationRevisions, listConfigurations, listKafkaVersions, listNodes, listReplicators, listScramSecrets, listTagsForResource, listVpcConnections, putClusterPolicy, rebootBroker, rejectClientVpcConnection, shutdown, tagResource, untagResource, updateBrokerCount, updateBrokerStorage, updateBrokerType, updateClusterConfiguration, updateClusterKafkaVersion, updateConfiguration, updateConnectivity, updateMonitoring, updateReplicationInfo, updateSecurity, updateStorage
Future<BatchAssociateScramSecretResult> batchAssociateScramSecretAsync(BatchAssociateScramSecretRequest batchAssociateScramSecretRequest)
Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecretRequest
- Associates sasl scram secrets to cluster.
Future<BatchAssociateScramSecretResult> batchAssociateScramSecretAsync(BatchAssociateScramSecretRequest batchAssociateScramSecretRequest, AsyncHandler<BatchAssociateScramSecretRequest,BatchAssociateScramSecretResult> asyncHandler)
Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecretRequest
- Associates sasl scram secrets to cluster.
asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<BatchDisassociateScramSecretResult> batchDisassociateScramSecretAsync(BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecretRequest
- Disassociates sasl scram secrets to cluster.
Future<BatchDisassociateScramSecretResult> batchDisassociateScramSecretAsync(BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest, AsyncHandler<BatchDisassociateScramSecretRequest,BatchDisassociateScramSecretResult> asyncHandler)
Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecretRequest
- Disassociates sasl scram secrets to cluster.
asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<CreateClusterResult> createClusterAsync(CreateClusterRequest createClusterRequest)
Creates a new MSK cluster.
createClusterRequest
- Future<CreateClusterResult> createClusterAsync(CreateClusterRequest createClusterRequest, AsyncHandler<CreateClusterRequest,CreateClusterResult> asyncHandler)
Creates a new MSK cluster.
createClusterRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<CreateClusterV2Result> createClusterV2Async(CreateClusterV2Request createClusterV2Request)
Creates a new MSK cluster.
createClusterV2Request
- Future<CreateClusterV2Result> createClusterV2Async(CreateClusterV2Request createClusterV2Request, AsyncHandler<CreateClusterV2Request,CreateClusterV2Result> asyncHandler)
Creates a new MSK cluster.
createClusterV2Request
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<CreateConfigurationResult> createConfigurationAsync(CreateConfigurationRequest createConfigurationRequest)
Creates a new MSK configuration.
createConfigurationRequest
- Future<CreateConfigurationResult> createConfigurationAsync(CreateConfigurationRequest createConfigurationRequest, AsyncHandler<CreateConfigurationRequest,CreateConfigurationResult> asyncHandler)
Creates a new MSK configuration.
createConfigurationRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<CreateReplicatorResult> createReplicatorAsync(CreateReplicatorRequest createReplicatorRequest)
Creates the replicator.
createReplicatorRequest
- Creates a replicator using the specified configuration.Future<CreateReplicatorResult> createReplicatorAsync(CreateReplicatorRequest createReplicatorRequest, AsyncHandler<CreateReplicatorRequest,CreateReplicatorResult> asyncHandler)
Creates the replicator.
createReplicatorRequest
- Creates a replicator using the specified configuration.asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<CreateVpcConnectionResult> createVpcConnectionAsync(CreateVpcConnectionRequest createVpcConnectionRequest)
Creates a new MSK VPC connection.
createVpcConnectionRequest
- Future<CreateVpcConnectionResult> createVpcConnectionAsync(CreateVpcConnectionRequest createVpcConnectionRequest, AsyncHandler<CreateVpcConnectionRequest,CreateVpcConnectionResult> asyncHandler)
Creates a new MSK VPC connection.
createVpcConnectionRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DeleteClusterResult> deleteClusterAsync(DeleteClusterRequest deleteClusterRequest)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteClusterRequest
- Future<DeleteClusterResult> deleteClusterAsync(DeleteClusterRequest deleteClusterRequest, AsyncHandler<DeleteClusterRequest,DeleteClusterResult> asyncHandler)
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteClusterRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DeleteClusterPolicyResult> deleteClusterPolicyAsync(DeleteClusterPolicyRequest deleteClusterPolicyRequest)
Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
deleteClusterPolicyRequest
- Future<DeleteClusterPolicyResult> deleteClusterPolicyAsync(DeleteClusterPolicyRequest deleteClusterPolicyRequest, AsyncHandler<DeleteClusterPolicyRequest,DeleteClusterPolicyResult> asyncHandler)
Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
deleteClusterPolicyRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DeleteConfigurationResult> deleteConfigurationAsync(DeleteConfigurationRequest deleteConfigurationRequest)
Deletes an MSK Configuration.
deleteConfigurationRequest
- Future<DeleteConfigurationResult> deleteConfigurationAsync(DeleteConfigurationRequest deleteConfigurationRequest, AsyncHandler<DeleteConfigurationRequest,DeleteConfigurationResult> asyncHandler)
Deletes an MSK Configuration.
deleteConfigurationRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DeleteReplicatorResult> deleteReplicatorAsync(DeleteReplicatorRequest deleteReplicatorRequest)
Deletes a replicator.
deleteReplicatorRequest
- Future<DeleteReplicatorResult> deleteReplicatorAsync(DeleteReplicatorRequest deleteReplicatorRequest, AsyncHandler<DeleteReplicatorRequest,DeleteReplicatorResult> asyncHandler)
Deletes a replicator.
deleteReplicatorRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DeleteVpcConnectionResult> deleteVpcConnectionAsync(DeleteVpcConnectionRequest deleteVpcConnectionRequest)
Deletes a MSK VPC connection.
deleteVpcConnectionRequest
- Future<DeleteVpcConnectionResult> deleteVpcConnectionAsync(DeleteVpcConnectionRequest deleteVpcConnectionRequest, AsyncHandler<DeleteVpcConnectionRequest,DeleteVpcConnectionResult> asyncHandler)
Deletes a MSK VPC connection.
deleteVpcConnectionRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeClusterResult> describeClusterAsync(DescribeClusterRequest describeClusterRequest)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterRequest
- Future<DescribeClusterResult> describeClusterAsync(DescribeClusterRequest describeClusterRequest, AsyncHandler<DescribeClusterRequest,DescribeClusterResult> asyncHandler)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeClusterOperationResult> describeClusterOperationAsync(DescribeClusterOperationRequest describeClusterOperationRequest)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationRequest
- Future<DescribeClusterOperationResult> describeClusterOperationAsync(DescribeClusterOperationRequest describeClusterOperationRequest, AsyncHandler<DescribeClusterOperationRequest,DescribeClusterOperationResult> asyncHandler)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeClusterOperationV2Result> describeClusterOperationV2Async(DescribeClusterOperationV2Request describeClusterOperationV2Request)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationV2Request
- Future<DescribeClusterOperationV2Result> describeClusterOperationV2Async(DescribeClusterOperationV2Request describeClusterOperationV2Request, AsyncHandler<DescribeClusterOperationV2Request,DescribeClusterOperationV2Result> asyncHandler)
Returns a description of the cluster operation specified by the ARN.
describeClusterOperationV2Request
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeClusterV2Result> describeClusterV2Async(DescribeClusterV2Request describeClusterV2Request)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2Request
- Future<DescribeClusterV2Result> describeClusterV2Async(DescribeClusterV2Request describeClusterV2Request, AsyncHandler<DescribeClusterV2Request,DescribeClusterV2Result> asyncHandler)
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2Request
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeConfigurationResult> describeConfigurationAsync(DescribeConfigurationRequest describeConfigurationRequest)
Returns a description of this MSK configuration.
describeConfigurationRequest
- Future<DescribeConfigurationResult> describeConfigurationAsync(DescribeConfigurationRequest describeConfigurationRequest, AsyncHandler<DescribeConfigurationRequest,DescribeConfigurationResult> asyncHandler)
Returns a description of this MSK configuration.
describeConfigurationRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeConfigurationRevisionResult> describeConfigurationRevisionAsync(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest)
Returns a description of this revision of the configuration.
describeConfigurationRevisionRequest
- Future<DescribeConfigurationRevisionResult> describeConfigurationRevisionAsync(DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest, AsyncHandler<DescribeConfigurationRevisionRequest,DescribeConfigurationRevisionResult> asyncHandler)
Returns a description of this revision of the configuration.
describeConfigurationRevisionRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeReplicatorResult> describeReplicatorAsync(DescribeReplicatorRequest describeReplicatorRequest)
Describes a replicator.
describeReplicatorRequest
- Future<DescribeReplicatorResult> describeReplicatorAsync(DescribeReplicatorRequest describeReplicatorRequest, AsyncHandler<DescribeReplicatorRequest,DescribeReplicatorResult> asyncHandler)
Describes a replicator.
describeReplicatorRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<DescribeVpcConnectionResult> describeVpcConnectionAsync(DescribeVpcConnectionRequest describeVpcConnectionRequest)
Returns a description of this MSK VPC connection.
describeVpcConnectionRequest
- Future<DescribeVpcConnectionResult> describeVpcConnectionAsync(DescribeVpcConnectionRequest describeVpcConnectionRequest, AsyncHandler<DescribeVpcConnectionRequest,DescribeVpcConnectionResult> asyncHandler)
Returns a description of this MSK VPC connection.
describeVpcConnectionRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<GetBootstrapBrokersResult> getBootstrapBrokersAsync(GetBootstrapBrokersRequest getBootstrapBrokersRequest)
A list of brokers that a client application can use to bootstrap.
getBootstrapBrokersRequest
- Future<GetBootstrapBrokersResult> getBootstrapBrokersAsync(GetBootstrapBrokersRequest getBootstrapBrokersRequest, AsyncHandler<GetBootstrapBrokersRequest,GetBootstrapBrokersResult> asyncHandler)
A list of brokers that a client application can use to bootstrap.
getBootstrapBrokersRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<GetClusterPolicyResult> getClusterPolicyAsync(GetClusterPolicyRequest getClusterPolicyRequest)
Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
getClusterPolicyRequest
- Future<GetClusterPolicyResult> getClusterPolicyAsync(GetClusterPolicyRequest getClusterPolicyRequest, AsyncHandler<GetClusterPolicyRequest,GetClusterPolicyResult> asyncHandler)
Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
getClusterPolicyRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<GetCompatibleKafkaVersionsResult> getCompatibleKafkaVersionsAsync(GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest)
Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersionsRequest
- Future<GetCompatibleKafkaVersionsResult> getCompatibleKafkaVersionsAsync(GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest, AsyncHandler<GetCompatibleKafkaVersionsRequest,GetCompatibleKafkaVersionsResult> asyncHandler)
Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersionsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListClientVpcConnectionsResult> listClientVpcConnectionsAsync(ListClientVpcConnectionsRequest listClientVpcConnectionsRequest)
Returns a list of all the VPC connections in this Region.
listClientVpcConnectionsRequest
- Future<ListClientVpcConnectionsResult> listClientVpcConnectionsAsync(ListClientVpcConnectionsRequest listClientVpcConnectionsRequest, AsyncHandler<ListClientVpcConnectionsRequest,ListClientVpcConnectionsResult> asyncHandler)
Returns a list of all the VPC connections in this Region.
listClientVpcConnectionsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListClusterOperationsResult> listClusterOperationsAsync(ListClusterOperationsRequest listClusterOperationsRequest)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsRequest
- Future<ListClusterOperationsResult> listClusterOperationsAsync(ListClusterOperationsRequest listClusterOperationsRequest, AsyncHandler<ListClusterOperationsRequest,ListClusterOperationsResult> asyncHandler)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListClusterOperationsV2Result> listClusterOperationsV2Async(ListClusterOperationsV2Request listClusterOperationsV2Request)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsV2Request
- Future<ListClusterOperationsV2Result> listClusterOperationsV2Async(ListClusterOperationsV2Request listClusterOperationsV2Request, AsyncHandler<ListClusterOperationsV2Request,ListClusterOperationsV2Result> asyncHandler)
Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsV2Request
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListClustersResult> listClustersAsync(ListClustersRequest listClustersRequest)
Returns a list of all the MSK clusters in the current Region.
listClustersRequest
- Future<ListClustersResult> listClustersAsync(ListClustersRequest listClustersRequest, AsyncHandler<ListClustersRequest,ListClustersResult> asyncHandler)
Returns a list of all the MSK clusters in the current Region.
listClustersRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListClustersV2Result> listClustersV2Async(ListClustersV2Request listClustersV2Request)
Returns a list of all the MSK clusters in the current Region.
listClustersV2Request
- Future<ListClustersV2Result> listClustersV2Async(ListClustersV2Request listClustersV2Request, AsyncHandler<ListClustersV2Request,ListClustersV2Result> asyncHandler)
Returns a list of all the MSK clusters in the current Region.
listClustersV2Request
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListConfigurationRevisionsResult> listConfigurationRevisionsAsync(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest)
Returns a list of all the MSK configurations in this Region.
listConfigurationRevisionsRequest
- Future<ListConfigurationRevisionsResult> listConfigurationRevisionsAsync(ListConfigurationRevisionsRequest listConfigurationRevisionsRequest, AsyncHandler<ListConfigurationRevisionsRequest,ListConfigurationRevisionsResult> asyncHandler)
Returns a list of all the MSK configurations in this Region.
listConfigurationRevisionsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListConfigurationsResult> listConfigurationsAsync(ListConfigurationsRequest listConfigurationsRequest)
Returns a list of all the MSK configurations in this Region.
listConfigurationsRequest
- Future<ListConfigurationsResult> listConfigurationsAsync(ListConfigurationsRequest listConfigurationsRequest, AsyncHandler<ListConfigurationsRequest,ListConfigurationsResult> asyncHandler)
Returns a list of all the MSK configurations in this Region.
listConfigurationsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListKafkaVersionsResult> listKafkaVersionsAsync(ListKafkaVersionsRequest listKafkaVersionsRequest)
Returns a list of Apache Kafka versions.
listKafkaVersionsRequest
- Future<ListKafkaVersionsResult> listKafkaVersionsAsync(ListKafkaVersionsRequest listKafkaVersionsRequest, AsyncHandler<ListKafkaVersionsRequest,ListKafkaVersionsResult> asyncHandler)
Returns a list of Apache Kafka versions.
listKafkaVersionsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListNodesResult> listNodesAsync(ListNodesRequest listNodesRequest)
Returns a list of the broker nodes in the cluster.
listNodesRequest
- Future<ListNodesResult> listNodesAsync(ListNodesRequest listNodesRequest, AsyncHandler<ListNodesRequest,ListNodesResult> asyncHandler)
Returns a list of the broker nodes in the cluster.
listNodesRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListReplicatorsResult> listReplicatorsAsync(ListReplicatorsRequest listReplicatorsRequest)
Lists the replicators.
listReplicatorsRequest
- Future<ListReplicatorsResult> listReplicatorsAsync(ListReplicatorsRequest listReplicatorsRequest, AsyncHandler<ListReplicatorsRequest,ListReplicatorsResult> asyncHandler)
Lists the replicators.
listReplicatorsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListScramSecretsResult> listScramSecretsAsync(ListScramSecretsRequest listScramSecretsRequest)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecretsRequest
- Future<ListScramSecretsResult> listScramSecretsAsync(ListScramSecretsRequest listScramSecretsRequest, AsyncHandler<ListScramSecretsRequest,ListScramSecretsResult> asyncHandler)
Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecretsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest)
Returns a list of the tags associated with the specified resource.
listTagsForResourceRequest
- Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest, AsyncHandler<ListTagsForResourceRequest,ListTagsForResourceResult> asyncHandler)
Returns a list of the tags associated with the specified resource.
listTagsForResourceRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<ListVpcConnectionsResult> listVpcConnectionsAsync(ListVpcConnectionsRequest listVpcConnectionsRequest)
Returns a list of all the VPC connections in this Region.
listVpcConnectionsRequest
- Future<ListVpcConnectionsResult> listVpcConnectionsAsync(ListVpcConnectionsRequest listVpcConnectionsRequest, AsyncHandler<ListVpcConnectionsRequest,ListVpcConnectionsResult> asyncHandler)
Returns a list of all the VPC connections in this Region.
listVpcConnectionsRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<PutClusterPolicyResult> putClusterPolicyAsync(PutClusterPolicyRequest putClusterPolicyRequest)
Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
putClusterPolicyRequest
- Future<PutClusterPolicyResult> putClusterPolicyAsync(PutClusterPolicyRequest putClusterPolicyRequest, AsyncHandler<PutClusterPolicyRequest,PutClusterPolicyResult> asyncHandler)
Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
putClusterPolicyRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<RebootBrokerResult> rebootBrokerAsync(RebootBrokerRequest rebootBrokerRequest)
rebootBrokerRequest
- Reboots a node.Future<RebootBrokerResult> rebootBrokerAsync(RebootBrokerRequest rebootBrokerRequest, AsyncHandler<RebootBrokerRequest,RebootBrokerResult> asyncHandler)
rebootBrokerRequest
- Reboots a node.asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<RejectClientVpcConnectionResult> rejectClientVpcConnectionAsync(RejectClientVpcConnectionRequest rejectClientVpcConnectionRequest)
Returns empty response.
rejectClientVpcConnectionRequest
- Future<RejectClientVpcConnectionResult> rejectClientVpcConnectionAsync(RejectClientVpcConnectionRequest rejectClientVpcConnectionRequest, AsyncHandler<RejectClientVpcConnectionRequest,RejectClientVpcConnectionResult> asyncHandler)
Returns empty response.
rejectClientVpcConnectionRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<TagResourceResult> tagResourceAsync(TagResourceRequest tagResourceRequest)
Adds tags to the specified MSK resource.
tagResourceRequest
- Future<TagResourceResult> tagResourceAsync(TagResourceRequest tagResourceRequest, AsyncHandler<TagResourceRequest,TagResourceResult> asyncHandler)
Adds tags to the specified MSK resource.
tagResourceRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest untagResourceRequest)
Removes the tags associated with the keys that are provided in the query.
untagResourceRequest
- Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest untagResourceRequest, AsyncHandler<UntagResourceRequest,UntagResourceResult> asyncHandler)
Removes the tags associated with the keys that are provided in the query.
untagResourceRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateBrokerCountResult> updateBrokerCountAsync(UpdateBrokerCountRequest updateBrokerCountRequest)
Updates the number of broker nodes in the cluster.
updateBrokerCountRequest
- Future<UpdateBrokerCountResult> updateBrokerCountAsync(UpdateBrokerCountRequest updateBrokerCountRequest, AsyncHandler<UpdateBrokerCountRequest,UpdateBrokerCountResult> asyncHandler)
Updates the number of broker nodes in the cluster.
updateBrokerCountRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateBrokerStorageResult> updateBrokerStorageAsync(UpdateBrokerStorageRequest updateBrokerStorageRequest)
Updates the EBS storage associated with MSK brokers.
updateBrokerStorageRequest
- Future<UpdateBrokerStorageResult> updateBrokerStorageAsync(UpdateBrokerStorageRequest updateBrokerStorageRequest, AsyncHandler<UpdateBrokerStorageRequest,UpdateBrokerStorageResult> asyncHandler)
Updates the EBS storage associated with MSK brokers.
updateBrokerStorageRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateBrokerTypeResult> updateBrokerTypeAsync(UpdateBrokerTypeRequest updateBrokerTypeRequest)
Updates EC2 instance type.
updateBrokerTypeRequest
- Future<UpdateBrokerTypeResult> updateBrokerTypeAsync(UpdateBrokerTypeRequest updateBrokerTypeRequest, AsyncHandler<UpdateBrokerTypeRequest,UpdateBrokerTypeResult> asyncHandler)
Updates EC2 instance type.
updateBrokerTypeRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateClusterConfigurationResult> updateClusterConfigurationAsync(UpdateClusterConfigurationRequest updateClusterConfigurationRequest)
Updates the cluster with the configuration that is specified in the request body.
updateClusterConfigurationRequest
- Future<UpdateClusterConfigurationResult> updateClusterConfigurationAsync(UpdateClusterConfigurationRequest updateClusterConfigurationRequest, AsyncHandler<UpdateClusterConfigurationRequest,UpdateClusterConfigurationResult> asyncHandler)
Updates the cluster with the configuration that is specified in the request body.
updateClusterConfigurationRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateClusterKafkaVersionResult> updateClusterKafkaVersionAsync(UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest)
Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersionRequest
- Future<UpdateClusterKafkaVersionResult> updateClusterKafkaVersionAsync(UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest, AsyncHandler<UpdateClusterKafkaVersionRequest,UpdateClusterKafkaVersionResult> asyncHandler)
Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersionRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateConfigurationResult> updateConfigurationAsync(UpdateConfigurationRequest updateConfigurationRequest)
Updates an MSK configuration.
updateConfigurationRequest
- Future<UpdateConfigurationResult> updateConfigurationAsync(UpdateConfigurationRequest updateConfigurationRequest, AsyncHandler<UpdateConfigurationRequest,UpdateConfigurationResult> asyncHandler)
Updates an MSK configuration.
updateConfigurationRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateConnectivityResult> updateConnectivityAsync(UpdateConnectivityRequest updateConnectivityRequest)
Updates the cluster's connectivity configuration.
updateConnectivityRequest
- Request body for UpdateConnectivity.Future<UpdateConnectivityResult> updateConnectivityAsync(UpdateConnectivityRequest updateConnectivityRequest, AsyncHandler<UpdateConnectivityRequest,UpdateConnectivityResult> asyncHandler)
Updates the cluster's connectivity configuration.
updateConnectivityRequest
- Request body for UpdateConnectivity.asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateMonitoringResult> updateMonitoringAsync(UpdateMonitoringRequest updateMonitoringRequest)
Updates the monitoring settings for the cluster. You can use this operation to specify which Apache Kafka metrics you want Amazon MSK to send to Amazon CloudWatch. You can also specify settings for open monitoring with Prometheus.
updateMonitoringRequest
- Request body for UpdateMonitoring.Future<UpdateMonitoringResult> updateMonitoringAsync(UpdateMonitoringRequest updateMonitoringRequest, AsyncHandler<UpdateMonitoringRequest,UpdateMonitoringResult> asyncHandler)
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.asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateReplicationInfoResult> updateReplicationInfoAsync(UpdateReplicationInfoRequest updateReplicationInfoRequest)
Updates replication info of a replicator.
updateReplicationInfoRequest
- Update information relating to replication between a given source and target Kafka cluster.Future<UpdateReplicationInfoResult> updateReplicationInfoAsync(UpdateReplicationInfoRequest updateReplicationInfoRequest, AsyncHandler<UpdateReplicationInfoRequest,UpdateReplicationInfoResult> asyncHandler)
Updates replication info of a replicator.
updateReplicationInfoRequest
- Update information relating to replication between a given source and target Kafka cluster.asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateSecurityResult> updateSecurityAsync(UpdateSecurityRequest updateSecurityRequest)
Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurityRequest
- Future<UpdateSecurityResult> updateSecurityAsync(UpdateSecurityRequest updateSecurityRequest, AsyncHandler<UpdateSecurityRequest,UpdateSecurityResult> asyncHandler)
Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurityRequest
- asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.Future<UpdateStorageResult> updateStorageAsync(UpdateStorageRequest updateStorageRequest)
updateStorageRequest
- Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
Future<UpdateStorageResult> updateStorageAsync(UpdateStorageRequest updateStorageRequest, AsyncHandler<UpdateStorageRequest,UpdateStorageResult> asyncHandler)
updateStorageRequest
- Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
asyncHandler
- Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.