@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class AbstractAWSKafkaAsync extends AbstractAWSKafka implements AWSKafkaAsync
AWSKafkaAsync. Convenient method forms pass through to the corresponding overload
that takes a request object and an AsyncHandler, which throws an UnsupportedOperationException.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 equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait 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 public Future<BatchAssociateScramSecretResult> batchAssociateScramSecretAsync(BatchAssociateScramSecretRequest request)
AWSKafkaAsync Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecretAsync in interface AWSKafkaAsync request - Associates sasl scram secrets to cluster.
public Future<BatchAssociateScramSecretResult> batchAssociateScramSecretAsync(BatchAssociateScramSecretRequest request, AsyncHandler<BatchAssociateScramSecretRequest,BatchAssociateScramSecretResult> asyncHandler)
AWSKafkaAsync Associates one or more Scram Secrets with an Amazon MSK cluster.
batchAssociateScramSecretAsync in interface AWSKafkaAsync request - 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.public Future<BatchDisassociateScramSecretResult> batchDisassociateScramSecretAsync(BatchDisassociateScramSecretRequest request)
AWSKafkaAsync Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecretAsync in interface AWSKafkaAsync request - Disassociates sasl scram secrets to cluster.
public Future<BatchDisassociateScramSecretResult> batchDisassociateScramSecretAsync(BatchDisassociateScramSecretRequest request, AsyncHandler<BatchDisassociateScramSecretRequest,BatchDisassociateScramSecretResult> asyncHandler)
AWSKafkaAsync Disassociates one or more Scram Secrets from an Amazon MSK cluster.
batchDisassociateScramSecretAsync in interface AWSKafkaAsync request - 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.public Future<CreateClusterResult> createClusterAsync(CreateClusterRequest request)
AWSKafkaAsync Creates a new MSK cluster.
createClusterAsync in interface AWSKafkaAsync public Future<CreateClusterResult> createClusterAsync(CreateClusterRequest request, AsyncHandler<CreateClusterRequest,CreateClusterResult> asyncHandler)
AWSKafkaAsync Creates a new MSK cluster.
createClusterAsync in interface AWSKafkaAsync 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.public Future<CreateClusterV2Result> createClusterV2Async(CreateClusterV2Request request)
AWSKafkaAsync Creates a new MSK cluster.
createClusterV2Async in interface AWSKafkaAsync public Future<CreateClusterV2Result> createClusterV2Async(CreateClusterV2Request request, AsyncHandler<CreateClusterV2Request,CreateClusterV2Result> asyncHandler)
AWSKafkaAsync Creates a new MSK cluster.
createClusterV2Async in interface AWSKafkaAsync 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.public Future<CreateConfigurationResult> createConfigurationAsync(CreateConfigurationRequest request)
AWSKafkaAsync Creates a new MSK configuration.
createConfigurationAsync in interface AWSKafkaAsync public Future<CreateConfigurationResult> createConfigurationAsync(CreateConfigurationRequest request, AsyncHandler<CreateConfigurationRequest,CreateConfigurationResult> asyncHandler)
AWSKafkaAsync Creates a new MSK configuration.
createConfigurationAsync in interface AWSKafkaAsync 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.public Future<CreateReplicatorResult> createReplicatorAsync(CreateReplicatorRequest request)
AWSKafkaAsync Creates the replicator.
createReplicatorAsync in interface AWSKafkaAsync request - Creates a replicator using the specified configuration.public Future<CreateReplicatorResult> createReplicatorAsync(CreateReplicatorRequest request, AsyncHandler<CreateReplicatorRequest,CreateReplicatorResult> asyncHandler)
AWSKafkaAsync Creates the replicator.
createReplicatorAsync in interface AWSKafkaAsync request - 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.public Future<CreateVpcConnectionResult> createVpcConnectionAsync(CreateVpcConnectionRequest request)
AWSKafkaAsync Creates a new MSK VPC connection.
createVpcConnectionAsync in interface AWSKafkaAsync public Future<CreateVpcConnectionResult> createVpcConnectionAsync(CreateVpcConnectionRequest request, AsyncHandler<CreateVpcConnectionRequest,CreateVpcConnectionResult> asyncHandler)
AWSKafkaAsync Creates a new MSK VPC connection.
createVpcConnectionAsync in interface AWSKafkaAsync 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.public Future<DeleteClusterResult> deleteClusterAsync(DeleteClusterRequest request)
AWSKafkaAsync Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteClusterAsync in interface AWSKafkaAsync public Future<DeleteClusterResult> deleteClusterAsync(DeleteClusterRequest request, AsyncHandler<DeleteClusterRequest,DeleteClusterResult> asyncHandler)
AWSKafkaAsync Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
deleteClusterAsync in interface AWSKafkaAsync 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.public Future<DeleteClusterPolicyResult> deleteClusterPolicyAsync(DeleteClusterPolicyRequest request)
AWSKafkaAsync Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
deleteClusterPolicyAsync in interface AWSKafkaAsync public Future<DeleteClusterPolicyResult> deleteClusterPolicyAsync(DeleteClusterPolicyRequest request, AsyncHandler<DeleteClusterPolicyRequest,DeleteClusterPolicyResult> asyncHandler)
AWSKafkaAsync Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
deleteClusterPolicyAsync in interface AWSKafkaAsync 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.public Future<DeleteConfigurationResult> deleteConfigurationAsync(DeleteConfigurationRequest request)
AWSKafkaAsync Deletes an MSK Configuration.
deleteConfigurationAsync in interface AWSKafkaAsync public Future<DeleteConfigurationResult> deleteConfigurationAsync(DeleteConfigurationRequest request, AsyncHandler<DeleteConfigurationRequest,DeleteConfigurationResult> asyncHandler)
AWSKafkaAsync Deletes an MSK Configuration.
deleteConfigurationAsync in interface AWSKafkaAsync 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.public Future<DeleteReplicatorResult> deleteReplicatorAsync(DeleteReplicatorRequest request)
AWSKafkaAsync Deletes a replicator.
deleteReplicatorAsync in interface AWSKafkaAsync public Future<DeleteReplicatorResult> deleteReplicatorAsync(DeleteReplicatorRequest request, AsyncHandler<DeleteReplicatorRequest,DeleteReplicatorResult> asyncHandler)
AWSKafkaAsync Deletes a replicator.
deleteReplicatorAsync in interface AWSKafkaAsync 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.public Future<DeleteVpcConnectionResult> deleteVpcConnectionAsync(DeleteVpcConnectionRequest request)
AWSKafkaAsync Deletes a MSK VPC connection.
deleteVpcConnectionAsync in interface AWSKafkaAsync public Future<DeleteVpcConnectionResult> deleteVpcConnectionAsync(DeleteVpcConnectionRequest request, AsyncHandler<DeleteVpcConnectionRequest,DeleteVpcConnectionResult> asyncHandler)
AWSKafkaAsync Deletes a MSK VPC connection.
deleteVpcConnectionAsync in interface AWSKafkaAsync 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.public Future<DescribeClusterResult> describeClusterAsync(DescribeClusterRequest request)
AWSKafkaAsync Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterAsync in interface AWSKafkaAsync public Future<DescribeClusterResult> describeClusterAsync(DescribeClusterRequest request, AsyncHandler<DescribeClusterRequest,DescribeClusterResult> asyncHandler)
AWSKafkaAsync Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterAsync in interface AWSKafkaAsync 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.public Future<DescribeClusterOperationResult> describeClusterOperationAsync(DescribeClusterOperationRequest request)
AWSKafkaAsync Returns a description of the cluster operation specified by the ARN.
describeClusterOperationAsync in interface AWSKafkaAsync public Future<DescribeClusterOperationResult> describeClusterOperationAsync(DescribeClusterOperationRequest request, AsyncHandler<DescribeClusterOperationRequest,DescribeClusterOperationResult> asyncHandler)
AWSKafkaAsync Returns a description of the cluster operation specified by the ARN.
describeClusterOperationAsync in interface AWSKafkaAsync 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.public Future<DescribeClusterOperationV2Result> describeClusterOperationV2Async(DescribeClusterOperationV2Request request)
AWSKafkaAsync Returns a description of the cluster operation specified by the ARN.
describeClusterOperationV2Async in interface AWSKafkaAsync public Future<DescribeClusterOperationV2Result> describeClusterOperationV2Async(DescribeClusterOperationV2Request request, AsyncHandler<DescribeClusterOperationV2Request,DescribeClusterOperationV2Result> asyncHandler)
AWSKafkaAsync Returns a description of the cluster operation specified by the ARN.
describeClusterOperationV2Async in interface AWSKafkaAsync 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.public Future<DescribeClusterV2Result> describeClusterV2Async(DescribeClusterV2Request request)
AWSKafkaAsync Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2Async in interface AWSKafkaAsync public Future<DescribeClusterV2Result> describeClusterV2Async(DescribeClusterV2Request request, AsyncHandler<DescribeClusterV2Request,DescribeClusterV2Result> asyncHandler)
AWSKafkaAsync Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
describeClusterV2Async in interface AWSKafkaAsync 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.public Future<DescribeConfigurationResult> describeConfigurationAsync(DescribeConfigurationRequest request)
AWSKafkaAsync Returns a description of this MSK configuration.
describeConfigurationAsync in interface AWSKafkaAsync public Future<DescribeConfigurationResult> describeConfigurationAsync(DescribeConfigurationRequest request, AsyncHandler<DescribeConfigurationRequest,DescribeConfigurationResult> asyncHandler)
AWSKafkaAsync Returns a description of this MSK configuration.
describeConfigurationAsync in interface AWSKafkaAsync 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.public Future<DescribeConfigurationRevisionResult> describeConfigurationRevisionAsync(DescribeConfigurationRevisionRequest request)
AWSKafkaAsync Returns a description of this revision of the configuration.
describeConfigurationRevisionAsync in interface AWSKafkaAsync public Future<DescribeConfigurationRevisionResult> describeConfigurationRevisionAsync(DescribeConfigurationRevisionRequest request, AsyncHandler<DescribeConfigurationRevisionRequest,DescribeConfigurationRevisionResult> asyncHandler)
AWSKafkaAsync Returns a description of this revision of the configuration.
describeConfigurationRevisionAsync in interface AWSKafkaAsync 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.public Future<DescribeReplicatorResult> describeReplicatorAsync(DescribeReplicatorRequest request)
AWSKafkaAsync Describes a replicator.
describeReplicatorAsync in interface AWSKafkaAsync public Future<DescribeReplicatorResult> describeReplicatorAsync(DescribeReplicatorRequest request, AsyncHandler<DescribeReplicatorRequest,DescribeReplicatorResult> asyncHandler)
AWSKafkaAsync Describes a replicator.
describeReplicatorAsync in interface AWSKafkaAsync 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.public Future<DescribeVpcConnectionResult> describeVpcConnectionAsync(DescribeVpcConnectionRequest request)
AWSKafkaAsync Returns a description of this MSK VPC connection.
describeVpcConnectionAsync in interface AWSKafkaAsync public Future<DescribeVpcConnectionResult> describeVpcConnectionAsync(DescribeVpcConnectionRequest request, AsyncHandler<DescribeVpcConnectionRequest,DescribeVpcConnectionResult> asyncHandler)
AWSKafkaAsync Returns a description of this MSK VPC connection.
describeVpcConnectionAsync in interface AWSKafkaAsync 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.public Future<GetBootstrapBrokersResult> getBootstrapBrokersAsync(GetBootstrapBrokersRequest request)
AWSKafkaAsync A list of brokers that a client application can use to bootstrap.
getBootstrapBrokersAsync in interface AWSKafkaAsync public Future<GetBootstrapBrokersResult> getBootstrapBrokersAsync(GetBootstrapBrokersRequest request, AsyncHandler<GetBootstrapBrokersRequest,GetBootstrapBrokersResult> asyncHandler)
AWSKafkaAsync A list of brokers that a client application can use to bootstrap.
getBootstrapBrokersAsync in interface AWSKafkaAsync 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.public Future<GetClusterPolicyResult> getClusterPolicyAsync(GetClusterPolicyRequest request)
AWSKafkaAsync Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
getClusterPolicyAsync in interface AWSKafkaAsync public Future<GetClusterPolicyResult> getClusterPolicyAsync(GetClusterPolicyRequest request, AsyncHandler<GetClusterPolicyRequest,GetClusterPolicyResult> asyncHandler)
AWSKafkaAsync Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
getClusterPolicyAsync in interface AWSKafkaAsync 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.public Future<GetCompatibleKafkaVersionsResult> getCompatibleKafkaVersionsAsync(GetCompatibleKafkaVersionsRequest request)
AWSKafkaAsync Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersionsAsync in interface AWSKafkaAsync public Future<GetCompatibleKafkaVersionsResult> getCompatibleKafkaVersionsAsync(GetCompatibleKafkaVersionsRequest request, AsyncHandler<GetCompatibleKafkaVersionsRequest,GetCompatibleKafkaVersionsResult> asyncHandler)
AWSKafkaAsync Gets the Apache Kafka versions to which you can update the MSK cluster.
getCompatibleKafkaVersionsAsync in interface AWSKafkaAsync 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.public Future<ListClientVpcConnectionsResult> listClientVpcConnectionsAsync(ListClientVpcConnectionsRequest request)
AWSKafkaAsync Returns a list of all the VPC connections in this Region.
listClientVpcConnectionsAsync in interface AWSKafkaAsync public Future<ListClientVpcConnectionsResult> listClientVpcConnectionsAsync(ListClientVpcConnectionsRequest request, AsyncHandler<ListClientVpcConnectionsRequest,ListClientVpcConnectionsResult> asyncHandler)
AWSKafkaAsync Returns a list of all the VPC connections in this Region.
listClientVpcConnectionsAsync in interface AWSKafkaAsync 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.public Future<ListClusterOperationsResult> listClusterOperationsAsync(ListClusterOperationsRequest request)
AWSKafkaAsync Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsAsync in interface AWSKafkaAsync public Future<ListClusterOperationsResult> listClusterOperationsAsync(ListClusterOperationsRequest request, AsyncHandler<ListClusterOperationsRequest,ListClusterOperationsResult> asyncHandler)
AWSKafkaAsync Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsAsync in interface AWSKafkaAsync 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.public Future<ListClusterOperationsV2Result> listClusterOperationsV2Async(ListClusterOperationsV2Request request)
AWSKafkaAsync Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsV2Async in interface AWSKafkaAsync public Future<ListClusterOperationsV2Result> listClusterOperationsV2Async(ListClusterOperationsV2Request request, AsyncHandler<ListClusterOperationsV2Request,ListClusterOperationsV2Result> asyncHandler)
AWSKafkaAsync Returns a list of all the operations that have been performed on the specified MSK cluster.
listClusterOperationsV2Async in interface AWSKafkaAsync 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.public Future<ListClustersResult> listClustersAsync(ListClustersRequest request)
AWSKafkaAsync Returns a list of all the MSK clusters in the current Region.
listClustersAsync in interface AWSKafkaAsync public Future<ListClustersResult> listClustersAsync(ListClustersRequest request, AsyncHandler<ListClustersRequest,ListClustersResult> asyncHandler)
AWSKafkaAsync Returns a list of all the MSK clusters in the current Region.
listClustersAsync in interface AWSKafkaAsync 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.public Future<ListClustersV2Result> listClustersV2Async(ListClustersV2Request request)
AWSKafkaAsync Returns a list of all the MSK clusters in the current Region.
listClustersV2Async in interface AWSKafkaAsync public Future<ListClustersV2Result> listClustersV2Async(ListClustersV2Request request, AsyncHandler<ListClustersV2Request,ListClustersV2Result> asyncHandler)
AWSKafkaAsync Returns a list of all the MSK clusters in the current Region.
listClustersV2Async in interface AWSKafkaAsync 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.public Future<ListConfigurationRevisionsResult> listConfigurationRevisionsAsync(ListConfigurationRevisionsRequest request)
AWSKafkaAsync Returns a list of all the MSK configurations in this Region.
listConfigurationRevisionsAsync in interface AWSKafkaAsync public Future<ListConfigurationRevisionsResult> listConfigurationRevisionsAsync(ListConfigurationRevisionsRequest request, AsyncHandler<ListConfigurationRevisionsRequest,ListConfigurationRevisionsResult> asyncHandler)
AWSKafkaAsync Returns a list of all the MSK configurations in this Region.
listConfigurationRevisionsAsync in interface AWSKafkaAsync 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.public Future<ListConfigurationsResult> listConfigurationsAsync(ListConfigurationsRequest request)
AWSKafkaAsync Returns a list of all the MSK configurations in this Region.
listConfigurationsAsync in interface AWSKafkaAsync public Future<ListConfigurationsResult> listConfigurationsAsync(ListConfigurationsRequest request, AsyncHandler<ListConfigurationsRequest,ListConfigurationsResult> asyncHandler)
AWSKafkaAsync Returns a list of all the MSK configurations in this Region.
listConfigurationsAsync in interface AWSKafkaAsync 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.public Future<ListKafkaVersionsResult> listKafkaVersionsAsync(ListKafkaVersionsRequest request)
AWSKafkaAsync Returns a list of Apache Kafka versions.
listKafkaVersionsAsync in interface AWSKafkaAsync public Future<ListKafkaVersionsResult> listKafkaVersionsAsync(ListKafkaVersionsRequest request, AsyncHandler<ListKafkaVersionsRequest,ListKafkaVersionsResult> asyncHandler)
AWSKafkaAsync Returns a list of Apache Kafka versions.
listKafkaVersionsAsync in interface AWSKafkaAsync 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.public Future<ListNodesResult> listNodesAsync(ListNodesRequest request)
AWSKafkaAsync Returns a list of the broker nodes in the cluster.
listNodesAsync in interface AWSKafkaAsync public Future<ListNodesResult> listNodesAsync(ListNodesRequest request, AsyncHandler<ListNodesRequest,ListNodesResult> asyncHandler)
AWSKafkaAsync Returns a list of the broker nodes in the cluster.
listNodesAsync in interface AWSKafkaAsync 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.public Future<ListReplicatorsResult> listReplicatorsAsync(ListReplicatorsRequest request)
AWSKafkaAsync Lists the replicators.
listReplicatorsAsync in interface AWSKafkaAsync public Future<ListReplicatorsResult> listReplicatorsAsync(ListReplicatorsRequest request, AsyncHandler<ListReplicatorsRequest,ListReplicatorsResult> asyncHandler)
AWSKafkaAsync Lists the replicators.
listReplicatorsAsync in interface AWSKafkaAsync 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.public Future<ListScramSecretsResult> listScramSecretsAsync(ListScramSecretsRequest request)
AWSKafkaAsync Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecretsAsync in interface AWSKafkaAsync public Future<ListScramSecretsResult> listScramSecretsAsync(ListScramSecretsRequest request, AsyncHandler<ListScramSecretsRequest,ListScramSecretsResult> asyncHandler)
AWSKafkaAsync Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
listScramSecretsAsync in interface AWSKafkaAsync 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.public Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest request)
AWSKafkaAsync Returns a list of the tags associated with the specified resource.
listTagsForResourceAsync in interface AWSKafkaAsync public Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest request, AsyncHandler<ListTagsForResourceRequest,ListTagsForResourceResult> asyncHandler)
AWSKafkaAsync Returns a list of the tags associated with the specified resource.
listTagsForResourceAsync in interface AWSKafkaAsync 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.public Future<ListVpcConnectionsResult> listVpcConnectionsAsync(ListVpcConnectionsRequest request)
AWSKafkaAsync Returns a list of all the VPC connections in this Region.
listVpcConnectionsAsync in interface AWSKafkaAsync public Future<ListVpcConnectionsResult> listVpcConnectionsAsync(ListVpcConnectionsRequest request, AsyncHandler<ListVpcConnectionsRequest,ListVpcConnectionsResult> asyncHandler)
AWSKafkaAsync Returns a list of all the VPC connections in this Region.
listVpcConnectionsAsync in interface AWSKafkaAsync 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.public Future<PutClusterPolicyResult> putClusterPolicyAsync(PutClusterPolicyRequest request)
AWSKafkaAsync Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
putClusterPolicyAsync in interface AWSKafkaAsync public Future<PutClusterPolicyResult> putClusterPolicyAsync(PutClusterPolicyRequest request, AsyncHandler<PutClusterPolicyRequest,PutClusterPolicyResult> asyncHandler)
AWSKafkaAsync Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
putClusterPolicyAsync in interface AWSKafkaAsync 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.public Future<RebootBrokerResult> rebootBrokerAsync(RebootBrokerRequest request)
AWSKafkaAsync rebootBrokerAsync in interface AWSKafkaAsync request - Reboots a node.public Future<RebootBrokerResult> rebootBrokerAsync(RebootBrokerRequest request, AsyncHandler<RebootBrokerRequest,RebootBrokerResult> asyncHandler)
AWSKafkaAsync rebootBrokerAsync in interface AWSKafkaAsync request - 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.public Future<RejectClientVpcConnectionResult> rejectClientVpcConnectionAsync(RejectClientVpcConnectionRequest request)
AWSKafkaAsync Returns empty response.
rejectClientVpcConnectionAsync in interface AWSKafkaAsync public Future<RejectClientVpcConnectionResult> rejectClientVpcConnectionAsync(RejectClientVpcConnectionRequest request, AsyncHandler<RejectClientVpcConnectionRequest,RejectClientVpcConnectionResult> asyncHandler)
AWSKafkaAsync Returns empty response.
rejectClientVpcConnectionAsync in interface AWSKafkaAsync 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.public Future<TagResourceResult> tagResourceAsync(TagResourceRequest request)
AWSKafkaAsync Adds tags to the specified MSK resource.
tagResourceAsync in interface AWSKafkaAsync public Future<TagResourceResult> tagResourceAsync(TagResourceRequest request, AsyncHandler<TagResourceRequest,TagResourceResult> asyncHandler)
AWSKafkaAsync Adds tags to the specified MSK resource.
tagResourceAsync in interface AWSKafkaAsync 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.public Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest request)
AWSKafkaAsync Removes the tags associated with the keys that are provided in the query.
untagResourceAsync in interface AWSKafkaAsync public Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest request, AsyncHandler<UntagResourceRequest,UntagResourceResult> asyncHandler)
AWSKafkaAsync Removes the tags associated with the keys that are provided in the query.
untagResourceAsync in interface AWSKafkaAsync 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.public Future<UpdateBrokerCountResult> updateBrokerCountAsync(UpdateBrokerCountRequest request)
AWSKafkaAsync Updates the number of broker nodes in the cluster.
updateBrokerCountAsync in interface AWSKafkaAsync public Future<UpdateBrokerCountResult> updateBrokerCountAsync(UpdateBrokerCountRequest request, AsyncHandler<UpdateBrokerCountRequest,UpdateBrokerCountResult> asyncHandler)
AWSKafkaAsync Updates the number of broker nodes in the cluster.
updateBrokerCountAsync in interface AWSKafkaAsync 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.public Future<UpdateBrokerStorageResult> updateBrokerStorageAsync(UpdateBrokerStorageRequest request)
AWSKafkaAsync Updates the EBS storage associated with MSK brokers.
updateBrokerStorageAsync in interface AWSKafkaAsync public Future<UpdateBrokerStorageResult> updateBrokerStorageAsync(UpdateBrokerStorageRequest request, AsyncHandler<UpdateBrokerStorageRequest,UpdateBrokerStorageResult> asyncHandler)
AWSKafkaAsync Updates the EBS storage associated with MSK brokers.
updateBrokerStorageAsync in interface AWSKafkaAsync 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.public Future<UpdateBrokerTypeResult> updateBrokerTypeAsync(UpdateBrokerTypeRequest request)
AWSKafkaAsync Updates EC2 instance type.
updateBrokerTypeAsync in interface AWSKafkaAsync public Future<UpdateBrokerTypeResult> updateBrokerTypeAsync(UpdateBrokerTypeRequest request, AsyncHandler<UpdateBrokerTypeRequest,UpdateBrokerTypeResult> asyncHandler)
AWSKafkaAsync Updates EC2 instance type.
updateBrokerTypeAsync in interface AWSKafkaAsync 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.public Future<UpdateClusterConfigurationResult> updateClusterConfigurationAsync(UpdateClusterConfigurationRequest request)
AWSKafkaAsync Updates the cluster with the configuration that is specified in the request body.
updateClusterConfigurationAsync in interface AWSKafkaAsync public Future<UpdateClusterConfigurationResult> updateClusterConfigurationAsync(UpdateClusterConfigurationRequest request, AsyncHandler<UpdateClusterConfigurationRequest,UpdateClusterConfigurationResult> asyncHandler)
AWSKafkaAsync Updates the cluster with the configuration that is specified in the request body.
updateClusterConfigurationAsync in interface AWSKafkaAsync 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.public Future<UpdateClusterKafkaVersionResult> updateClusterKafkaVersionAsync(UpdateClusterKafkaVersionRequest request)
AWSKafkaAsync Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersionAsync in interface AWSKafkaAsync public Future<UpdateClusterKafkaVersionResult> updateClusterKafkaVersionAsync(UpdateClusterKafkaVersionRequest request, AsyncHandler<UpdateClusterKafkaVersionRequest,UpdateClusterKafkaVersionResult> asyncHandler)
AWSKafkaAsync Updates the Apache Kafka version for the cluster.
updateClusterKafkaVersionAsync in interface AWSKafkaAsync 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.public Future<UpdateConfigurationResult> updateConfigurationAsync(UpdateConfigurationRequest request)
AWSKafkaAsync Updates an MSK configuration.
updateConfigurationAsync in interface AWSKafkaAsync public Future<UpdateConfigurationResult> updateConfigurationAsync(UpdateConfigurationRequest request, AsyncHandler<UpdateConfigurationRequest,UpdateConfigurationResult> asyncHandler)
AWSKafkaAsync Updates an MSK configuration.
updateConfigurationAsync in interface AWSKafkaAsync 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.public Future<UpdateConnectivityResult> updateConnectivityAsync(UpdateConnectivityRequest request)
AWSKafkaAsync Updates the cluster's connectivity configuration.
updateConnectivityAsync in interface AWSKafkaAsync request - Request body for UpdateConnectivity.public Future<UpdateConnectivityResult> updateConnectivityAsync(UpdateConnectivityRequest request, AsyncHandler<UpdateConnectivityRequest,UpdateConnectivityResult> asyncHandler)
AWSKafkaAsync Updates the cluster's connectivity configuration.
updateConnectivityAsync in interface AWSKafkaAsync request - 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.public Future<UpdateMonitoringResult> updateMonitoringAsync(UpdateMonitoringRequest request)
AWSKafkaAsync 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.
updateMonitoringAsync in interface AWSKafkaAsync request - Request body for UpdateMonitoring.public Future<UpdateMonitoringResult> updateMonitoringAsync(UpdateMonitoringRequest request, AsyncHandler<UpdateMonitoringRequest,UpdateMonitoringResult> asyncHandler)
AWSKafkaAsync 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.
updateMonitoringAsync in interface AWSKafkaAsync request - 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.public Future<UpdateReplicationInfoResult> updateReplicationInfoAsync(UpdateReplicationInfoRequest request)
AWSKafkaAsync Updates replication info of a replicator.
updateReplicationInfoAsync in interface AWSKafkaAsync request - Update information relating to replication between a given source and target Kafka cluster.public Future<UpdateReplicationInfoResult> updateReplicationInfoAsync(UpdateReplicationInfoRequest request, AsyncHandler<UpdateReplicationInfoRequest,UpdateReplicationInfoResult> asyncHandler)
AWSKafkaAsync Updates replication info of a replicator.
updateReplicationInfoAsync in interface AWSKafkaAsync request - 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.public Future<UpdateSecurityResult> updateSecurityAsync(UpdateSecurityRequest request)
AWSKafkaAsync Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurityAsync in interface AWSKafkaAsync public Future<UpdateSecurityResult> updateSecurityAsync(UpdateSecurityRequest request, AsyncHandler<UpdateSecurityRequest,UpdateSecurityResult> asyncHandler)
AWSKafkaAsync Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.
updateSecurityAsync in interface AWSKafkaAsync 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.public Future<UpdateStorageResult> updateStorageAsync(UpdateStorageRequest request)
AWSKafkaAsync updateStorageAsync in interface AWSKafkaAsync request - Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
public Future<UpdateStorageResult> updateStorageAsync(UpdateStorageRequest request, AsyncHandler<UpdateStorageRequest,UpdateStorageResult> asyncHandler)
AWSKafkaAsync updateStorageAsync in interface AWSKafkaAsync request - 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.