/*
* Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
* the License. A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
* CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
* and limitations under the License.
*/
package com.amazonaws.services.kafka;
import javax.annotation.Generated;
import com.amazonaws.services.kafka.model.*;
/**
* Interface for accessing Kafka asynchronously. Each asynchronous method will return a Java Future object representing
* the asynchronous operation; overloads which accept an {@code AsyncHandler} can be used to receive notification when
* an asynchronous operation completes.
* <p>
* <b>Note:</b> Do not directly implement this interface, new methods are added to it regularly. Extend from
* {@link com.amazonaws.services.kafka.AbstractAWSKafkaAsync} instead.
* </p>
* <p>
*
* <p>
* The operations for managing an Amazon MSK cluster.
* </p>
*/
@Generated("com.amazonaws:aws-java-sdk-code-generator")
public interface AWSKafkaAsync extends AWSKafka {
/**
* <p>
* Associates one or more Scram Secrets with an Amazon MSK cluster.
* </p>
*
* @param batchAssociateScramSecretRequest
* <p>
* Associates sasl scram secrets to cluster.
* </p>
* @return A Java Future containing the result of the BatchAssociateScramSecret operation returned by the service.
* @sample AWSKafkaAsync.BatchAssociateScramSecret
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BatchAssociateScramSecret"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<BatchAssociateScramSecretResult> batchAssociateScramSecretAsync(
BatchAssociateScramSecretRequest batchAssociateScramSecretRequest);
/**
* <p>
* Associates one or more Scram Secrets with an Amazon MSK cluster.
* </p>
*
* @param batchAssociateScramSecretRequest
* <p>
* Associates sasl scram secrets to cluster.
* </p>
* @param 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.
* @return A Java Future containing the result of the BatchAssociateScramSecret operation returned by the service.
* @sample AWSKafkaAsyncHandler.BatchAssociateScramSecret
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BatchAssociateScramSecret"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<BatchAssociateScramSecretResult> batchAssociateScramSecretAsync(
BatchAssociateScramSecretRequest batchAssociateScramSecretRequest,
com.amazonaws.handlers.AsyncHandler<BatchAssociateScramSecretRequest, BatchAssociateScramSecretResult> asyncHandler);
/**
* <p>
* Disassociates one or more Scram Secrets from an Amazon MSK cluster.
* </p>
*
* @param batchDisassociateScramSecretRequest
* <p>
* Disassociates sasl scram secrets to cluster.
* </p>
* @return A Java Future containing the result of the BatchDisassociateScramSecret operation returned by the
* service.
* @sample AWSKafkaAsync.BatchDisassociateScramSecret
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BatchDisassociateScramSecret"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<BatchDisassociateScramSecretResult> batchDisassociateScramSecretAsync(
BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest);
/**
* <p>
* Disassociates one or more Scram Secrets from an Amazon MSK cluster.
* </p>
*
* @param batchDisassociateScramSecretRequest
* <p>
* Disassociates sasl scram secrets to cluster.
* </p>
* @param 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.
* @return A Java Future containing the result of the BatchDisassociateScramSecret operation returned by the
* service.
* @sample AWSKafkaAsyncHandler.BatchDisassociateScramSecret
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BatchDisassociateScramSecret"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<BatchDisassociateScramSecretResult> batchDisassociateScramSecretAsync(
BatchDisassociateScramSecretRequest batchDisassociateScramSecretRequest,
com.amazonaws.handlers.AsyncHandler<BatchDisassociateScramSecretRequest, BatchDisassociateScramSecretResult> asyncHandler);
/**
* <p>
* Creates a new MSK cluster.
* </p>
*
* @param createClusterRequest
* @return A Java Future containing the result of the CreateCluster operation returned by the service.
* @sample AWSKafkaAsync.CreateCluster
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateCluster" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateClusterResult> createClusterAsync(CreateClusterRequest createClusterRequest);
/**
* <p>
* Creates a new MSK cluster.
* </p>
*
* @param createClusterRequest
* @param 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.
* @return A Java Future containing the result of the CreateCluster operation returned by the service.
* @sample AWSKafkaAsyncHandler.CreateCluster
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateCluster" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateClusterResult> createClusterAsync(CreateClusterRequest createClusterRequest,
com.amazonaws.handlers.AsyncHandler<CreateClusterRequest, CreateClusterResult> asyncHandler);
/**
* <p>
* Creates a new MSK cluster.
* </p>
*
* @param createClusterV2Request
* @return A Java Future containing the result of the CreateClusterV2 operation returned by the service.
* @sample AWSKafkaAsync.CreateClusterV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateClusterV2" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateClusterV2Result> createClusterV2Async(CreateClusterV2Request createClusterV2Request);
/**
* <p>
* Creates a new MSK cluster.
* </p>
*
* @param createClusterV2Request
* @param 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.
* @return A Java Future containing the result of the CreateClusterV2 operation returned by the service.
* @sample AWSKafkaAsyncHandler.CreateClusterV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateClusterV2" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateClusterV2Result> createClusterV2Async(CreateClusterV2Request createClusterV2Request,
com.amazonaws.handlers.AsyncHandler<CreateClusterV2Request, CreateClusterV2Result> asyncHandler);
/**
* <p>
* Creates a new MSK configuration.
* </p>
*
* @param createConfigurationRequest
* @return A Java Future containing the result of the CreateConfiguration operation returned by the service.
* @sample AWSKafkaAsync.CreateConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfiguration" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateConfigurationResult> createConfigurationAsync(CreateConfigurationRequest createConfigurationRequest);
/**
* <p>
* Creates a new MSK configuration.
* </p>
*
* @param createConfigurationRequest
* @param 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.
* @return A Java Future containing the result of the CreateConfiguration operation returned by the service.
* @sample AWSKafkaAsyncHandler.CreateConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfiguration" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateConfigurationResult> createConfigurationAsync(CreateConfigurationRequest createConfigurationRequest,
com.amazonaws.handlers.AsyncHandler<CreateConfigurationRequest, CreateConfigurationResult> asyncHandler);
/**
* <p>
* Creates a new MSK VPC connection.
* </p>
*
* @param createVpcConnectionRequest
* @return A Java Future containing the result of the CreateVpcConnection operation returned by the service.
* @sample AWSKafkaAsync.CreateVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateVpcConnection" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateVpcConnectionResult> createVpcConnectionAsync(CreateVpcConnectionRequest createVpcConnectionRequest);
/**
* <p>
* Creates a new MSK VPC connection.
* </p>
*
* @param createVpcConnectionRequest
* @param 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.
* @return A Java Future containing the result of the CreateVpcConnection operation returned by the service.
* @sample AWSKafkaAsyncHandler.CreateVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateVpcConnection" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<CreateVpcConnectionResult> createVpcConnectionAsync(CreateVpcConnectionRequest createVpcConnectionRequest,
com.amazonaws.handlers.AsyncHandler<CreateVpcConnectionRequest, CreateVpcConnectionResult> asyncHandler);
/**
* <p>
* Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
* </p>
*
* @param deleteClusterRequest
* @return A Java Future containing the result of the DeleteCluster operation returned by the service.
* @sample AWSKafkaAsync.DeleteCluster
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteCluster" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteClusterResult> deleteClusterAsync(DeleteClusterRequest deleteClusterRequest);
/**
* <p>
* Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
* </p>
*
* @param deleteClusterRequest
* @param 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.
* @return A Java Future containing the result of the DeleteCluster operation returned by the service.
* @sample AWSKafkaAsyncHandler.DeleteCluster
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteCluster" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteClusterResult> deleteClusterAsync(DeleteClusterRequest deleteClusterRequest,
com.amazonaws.handlers.AsyncHandler<DeleteClusterRequest, DeleteClusterResult> asyncHandler);
/**
* <p>
* Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
* </p>
*
* @param deleteClusterPolicyRequest
* @return A Java Future containing the result of the DeleteClusterPolicy operation returned by the service.
* @sample AWSKafkaAsync.DeleteClusterPolicy
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteClusterPolicy" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteClusterPolicyResult> deleteClusterPolicyAsync(DeleteClusterPolicyRequest deleteClusterPolicyRequest);
/**
* <p>
* Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
* </p>
*
* @param deleteClusterPolicyRequest
* @param 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.
* @return A Java Future containing the result of the DeleteClusterPolicy operation returned by the service.
* @sample AWSKafkaAsyncHandler.DeleteClusterPolicy
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteClusterPolicy" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteClusterPolicyResult> deleteClusterPolicyAsync(DeleteClusterPolicyRequest deleteClusterPolicyRequest,
com.amazonaws.handlers.AsyncHandler<DeleteClusterPolicyRequest, DeleteClusterPolicyResult> asyncHandler);
/**
* <p>
* Deletes an MSK Configuration.
* </p>
*
* @param deleteConfigurationRequest
* @return A Java Future containing the result of the DeleteConfiguration operation returned by the service.
* @sample AWSKafkaAsync.DeleteConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteConfiguration" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteConfigurationResult> deleteConfigurationAsync(DeleteConfigurationRequest deleteConfigurationRequest);
/**
* <p>
* Deletes an MSK Configuration.
* </p>
*
* @param deleteConfigurationRequest
* @param 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.
* @return A Java Future containing the result of the DeleteConfiguration operation returned by the service.
* @sample AWSKafkaAsyncHandler.DeleteConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteConfiguration" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteConfigurationResult> deleteConfigurationAsync(DeleteConfigurationRequest deleteConfigurationRequest,
com.amazonaws.handlers.AsyncHandler<DeleteConfigurationRequest, DeleteConfigurationResult> asyncHandler);
/**
* <p>
* Deletes a MSK VPC connection.
* </p>
*
* @param deleteVpcConnectionRequest
* @return A Java Future containing the result of the DeleteVpcConnection operation returned by the service.
* @sample AWSKafkaAsync.DeleteVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteVpcConnection" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteVpcConnectionResult> deleteVpcConnectionAsync(DeleteVpcConnectionRequest deleteVpcConnectionRequest);
/**
* <p>
* Deletes a MSK VPC connection.
* </p>
*
* @param deleteVpcConnectionRequest
* @param 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.
* @return A Java Future containing the result of the DeleteVpcConnection operation returned by the service.
* @sample AWSKafkaAsyncHandler.DeleteVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteVpcConnection" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DeleteVpcConnectionResult> deleteVpcConnectionAsync(DeleteVpcConnectionRequest deleteVpcConnectionRequest,
com.amazonaws.handlers.AsyncHandler<DeleteVpcConnectionRequest, DeleteVpcConnectionResult> asyncHandler);
/**
* <p>
* Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
* </p>
*
* @param describeClusterRequest
* @return A Java Future containing the result of the DescribeCluster operation returned by the service.
* @sample AWSKafkaAsync.DescribeCluster
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeCluster" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterResult> describeClusterAsync(DescribeClusterRequest describeClusterRequest);
/**
* <p>
* Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
* </p>
*
* @param describeClusterRequest
* @param 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.
* @return A Java Future containing the result of the DescribeCluster operation returned by the service.
* @sample AWSKafkaAsyncHandler.DescribeCluster
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeCluster" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterResult> describeClusterAsync(DescribeClusterRequest describeClusterRequest,
com.amazonaws.handlers.AsyncHandler<DescribeClusterRequest, DescribeClusterResult> asyncHandler);
/**
* <p>
* Returns a description of the cluster operation specified by the ARN.
* </p>
*
* @param describeClusterOperationRequest
* @return A Java Future containing the result of the DescribeClusterOperation operation returned by the service.
* @sample AWSKafkaAsync.DescribeClusterOperation
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperation" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterOperationResult> describeClusterOperationAsync(DescribeClusterOperationRequest describeClusterOperationRequest);
/**
* <p>
* Returns a description of the cluster operation specified by the ARN.
* </p>
*
* @param describeClusterOperationRequest
* @param 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.
* @return A Java Future containing the result of the DescribeClusterOperation operation returned by the service.
* @sample AWSKafkaAsyncHandler.DescribeClusterOperation
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperation" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterOperationResult> describeClusterOperationAsync(DescribeClusterOperationRequest describeClusterOperationRequest,
com.amazonaws.handlers.AsyncHandler<DescribeClusterOperationRequest, DescribeClusterOperationResult> asyncHandler);
/**
* <p>
* Returns a description of the cluster operation specified by the ARN.
* </p>
*
* @param describeClusterOperationV2Request
* @return A Java Future containing the result of the DescribeClusterOperationV2 operation returned by the service.
* @sample AWSKafkaAsync.DescribeClusterOperationV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperationV2"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterOperationV2Result> describeClusterOperationV2Async(
DescribeClusterOperationV2Request describeClusterOperationV2Request);
/**
* <p>
* Returns a description of the cluster operation specified by the ARN.
* </p>
*
* @param describeClusterOperationV2Request
* @param 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.
* @return A Java Future containing the result of the DescribeClusterOperationV2 operation returned by the service.
* @sample AWSKafkaAsyncHandler.DescribeClusterOperationV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperationV2"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterOperationV2Result> describeClusterOperationV2Async(
DescribeClusterOperationV2Request describeClusterOperationV2Request,
com.amazonaws.handlers.AsyncHandler<DescribeClusterOperationV2Request, DescribeClusterOperationV2Result> asyncHandler);
/**
* <p>
* Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
* </p>
*
* @param describeClusterV2Request
* @return A Java Future containing the result of the DescribeClusterV2 operation returned by the service.
* @sample AWSKafkaAsync.DescribeClusterV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterV2" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterV2Result> describeClusterV2Async(DescribeClusterV2Request describeClusterV2Request);
/**
* <p>
* Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
* </p>
*
* @param describeClusterV2Request
* @param 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.
* @return A Java Future containing the result of the DescribeClusterV2 operation returned by the service.
* @sample AWSKafkaAsyncHandler.DescribeClusterV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterV2" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<DescribeClusterV2Result> describeClusterV2Async(DescribeClusterV2Request describeClusterV2Request,
com.amazonaws.handlers.AsyncHandler<DescribeClusterV2Request, DescribeClusterV2Result> asyncHandler);
/**
* <p>
* Returns a description of this MSK configuration.
* </p>
*
* @param describeConfigurationRequest
* @return A Java Future containing the result of the DescribeConfiguration operation returned by the service.
* @sample AWSKafkaAsync.DescribeConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfiguration" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<DescribeConfigurationResult> describeConfigurationAsync(DescribeConfigurationRequest describeConfigurationRequest);
/**
* <p>
* Returns a description of this MSK configuration.
* </p>
*
* @param describeConfigurationRequest
* @param 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.
* @return A Java Future containing the result of the DescribeConfiguration operation returned by the service.
* @sample AWSKafkaAsyncHandler.DescribeConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfiguration" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<DescribeConfigurationResult> describeConfigurationAsync(DescribeConfigurationRequest describeConfigurationRequest,
com.amazonaws.handlers.AsyncHandler<DescribeConfigurationRequest, DescribeConfigurationResult> asyncHandler);
/**
* <p>
* Returns a description of this revision of the configuration.
* </p>
*
* @param describeConfigurationRevisionRequest
* @return A Java Future containing the result of the DescribeConfigurationRevision operation returned by the
* service.
* @sample AWSKafkaAsync.DescribeConfigurationRevision
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevision"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<DescribeConfigurationRevisionResult> describeConfigurationRevisionAsync(
DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest);
/**
* <p>
* Returns a description of this revision of the configuration.
* </p>
*
* @param describeConfigurationRevisionRequest
* @param 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.
* @return A Java Future containing the result of the DescribeConfigurationRevision operation returned by the
* service.
* @sample AWSKafkaAsyncHandler.DescribeConfigurationRevision
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevision"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<DescribeConfigurationRevisionResult> describeConfigurationRevisionAsync(
DescribeConfigurationRevisionRequest describeConfigurationRevisionRequest,
com.amazonaws.handlers.AsyncHandler<DescribeConfigurationRevisionRequest, DescribeConfigurationRevisionResult> asyncHandler);
/**
* <p>
* Returns a description of this MSK VPC connection.
* </p>
*
* @param describeVpcConnectionRequest
* @return A Java Future containing the result of the DescribeVpcConnection operation returned by the service.
* @sample AWSKafkaAsync.DescribeVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeVpcConnection" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<DescribeVpcConnectionResult> describeVpcConnectionAsync(DescribeVpcConnectionRequest describeVpcConnectionRequest);
/**
* <p>
* Returns a description of this MSK VPC connection.
* </p>
*
* @param describeVpcConnectionRequest
* @param 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.
* @return A Java Future containing the result of the DescribeVpcConnection operation returned by the service.
* @sample AWSKafkaAsyncHandler.DescribeVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeVpcConnection" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<DescribeVpcConnectionResult> describeVpcConnectionAsync(DescribeVpcConnectionRequest describeVpcConnectionRequest,
com.amazonaws.handlers.AsyncHandler<DescribeVpcConnectionRequest, DescribeVpcConnectionResult> asyncHandler);
/**
* <p>
* A list of brokers that a client application can use to bootstrap.
* </p>
*
* @param getBootstrapBrokersRequest
* @return A Java Future containing the result of the GetBootstrapBrokers operation returned by the service.
* @sample AWSKafkaAsync.GetBootstrapBrokers
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokers" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<GetBootstrapBrokersResult> getBootstrapBrokersAsync(GetBootstrapBrokersRequest getBootstrapBrokersRequest);
/**
* <p>
* A list of brokers that a client application can use to bootstrap.
* </p>
*
* @param getBootstrapBrokersRequest
* @param 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.
* @return A Java Future containing the result of the GetBootstrapBrokers operation returned by the service.
* @sample AWSKafkaAsyncHandler.GetBootstrapBrokers
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokers" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<GetBootstrapBrokersResult> getBootstrapBrokersAsync(GetBootstrapBrokersRequest getBootstrapBrokersRequest,
com.amazonaws.handlers.AsyncHandler<GetBootstrapBrokersRequest, GetBootstrapBrokersResult> asyncHandler);
/**
* <p>
* Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
* </p>
*
* @param getClusterPolicyRequest
* @return A Java Future containing the result of the GetClusterPolicy operation returned by the service.
* @sample AWSKafkaAsync.GetClusterPolicy
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetClusterPolicy" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<GetClusterPolicyResult> getClusterPolicyAsync(GetClusterPolicyRequest getClusterPolicyRequest);
/**
* <p>
* Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
* </p>
*
* @param getClusterPolicyRequest
* @param 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.
* @return A Java Future containing the result of the GetClusterPolicy operation returned by the service.
* @sample AWSKafkaAsyncHandler.GetClusterPolicy
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetClusterPolicy" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<GetClusterPolicyResult> getClusterPolicyAsync(GetClusterPolicyRequest getClusterPolicyRequest,
com.amazonaws.handlers.AsyncHandler<GetClusterPolicyRequest, GetClusterPolicyResult> asyncHandler);
/**
* <p>
* Gets the Apache Kafka versions to which you can update the MSK cluster.
* </p>
*
* @param getCompatibleKafkaVersionsRequest
* @return A Java Future containing the result of the GetCompatibleKafkaVersions operation returned by the service.
* @sample AWSKafkaAsync.GetCompatibleKafkaVersions
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetCompatibleKafkaVersions"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<GetCompatibleKafkaVersionsResult> getCompatibleKafkaVersionsAsync(
GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest);
/**
* <p>
* Gets the Apache Kafka versions to which you can update the MSK cluster.
* </p>
*
* @param getCompatibleKafkaVersionsRequest
* @param 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.
* @return A Java Future containing the result of the GetCompatibleKafkaVersions operation returned by the service.
* @sample AWSKafkaAsyncHandler.GetCompatibleKafkaVersions
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetCompatibleKafkaVersions"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<GetCompatibleKafkaVersionsResult> getCompatibleKafkaVersionsAsync(
GetCompatibleKafkaVersionsRequest getCompatibleKafkaVersionsRequest,
com.amazonaws.handlers.AsyncHandler<GetCompatibleKafkaVersionsRequest, GetCompatibleKafkaVersionsResult> asyncHandler);
/**
* <p>
* Returns a list of all the VPC connections in this Region.
* </p>
*
* @param listClientVpcConnectionsRequest
* @return A Java Future containing the result of the ListClientVpcConnections operation returned by the service.
* @sample AWSKafkaAsync.ListClientVpcConnections
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClientVpcConnections" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<ListClientVpcConnectionsResult> listClientVpcConnectionsAsync(ListClientVpcConnectionsRequest listClientVpcConnectionsRequest);
/**
* <p>
* Returns a list of all the VPC connections in this Region.
* </p>
*
* @param listClientVpcConnectionsRequest
* @param 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.
* @return A Java Future containing the result of the ListClientVpcConnections operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListClientVpcConnections
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClientVpcConnections" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<ListClientVpcConnectionsResult> listClientVpcConnectionsAsync(ListClientVpcConnectionsRequest listClientVpcConnectionsRequest,
com.amazonaws.handlers.AsyncHandler<ListClientVpcConnectionsRequest, ListClientVpcConnectionsResult> asyncHandler);
/**
* <p>
* Returns a list of all the operations that have been performed on the specified MSK cluster.
* </p>
*
* @param listClusterOperationsRequest
* @return A Java Future containing the result of the ListClusterOperations operation returned by the service.
* @sample AWSKafkaAsync.ListClusterOperations
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperations" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<ListClusterOperationsResult> listClusterOperationsAsync(ListClusterOperationsRequest listClusterOperationsRequest);
/**
* <p>
* Returns a list of all the operations that have been performed on the specified MSK cluster.
* </p>
*
* @param listClusterOperationsRequest
* @param 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.
* @return A Java Future containing the result of the ListClusterOperations operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListClusterOperations
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperations" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<ListClusterOperationsResult> listClusterOperationsAsync(ListClusterOperationsRequest listClusterOperationsRequest,
com.amazonaws.handlers.AsyncHandler<ListClusterOperationsRequest, ListClusterOperationsResult> asyncHandler);
/**
* <p>
* Returns a list of all the operations that have been performed on the specified MSK cluster.
* </p>
*
* @param listClusterOperationsV2Request
* @return A Java Future containing the result of the ListClusterOperationsV2 operation returned by the service.
* @sample AWSKafkaAsync.ListClusterOperationsV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperationsV2" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<ListClusterOperationsV2Result> listClusterOperationsV2Async(ListClusterOperationsV2Request listClusterOperationsV2Request);
/**
* <p>
* Returns a list of all the operations that have been performed on the specified MSK cluster.
* </p>
*
* @param listClusterOperationsV2Request
* @param 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.
* @return A Java Future containing the result of the ListClusterOperationsV2 operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListClusterOperationsV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperationsV2" target="_top">AWS
* API Documentation</a>
*/
java.util.concurrent.Future<ListClusterOperationsV2Result> listClusterOperationsV2Async(ListClusterOperationsV2Request listClusterOperationsV2Request,
com.amazonaws.handlers.AsyncHandler<ListClusterOperationsV2Request, ListClusterOperationsV2Result> asyncHandler);
/**
* <p>
* Returns a list of all the MSK clusters in the current Region.
* </p>
*
* @param listClustersRequest
* @return A Java Future containing the result of the ListClusters operation returned by the service.
* @sample AWSKafkaAsync.ListClusters
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusters" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListClustersResult> listClustersAsync(ListClustersRequest listClustersRequest);
/**
* <p>
* Returns a list of all the MSK clusters in the current Region.
* </p>
*
* @param listClustersRequest
* @param 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.
* @return A Java Future containing the result of the ListClusters operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListClusters
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusters" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListClustersResult> listClustersAsync(ListClustersRequest listClustersRequest,
com.amazonaws.handlers.AsyncHandler<ListClustersRequest, ListClustersResult> asyncHandler);
/**
* <p>
* Returns a list of all the MSK clusters in the current Region.
* </p>
*
* @param listClustersV2Request
* @return A Java Future containing the result of the ListClustersV2 operation returned by the service.
* @sample AWSKafkaAsync.ListClustersV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClustersV2" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListClustersV2Result> listClustersV2Async(ListClustersV2Request listClustersV2Request);
/**
* <p>
* Returns a list of all the MSK clusters in the current Region.
* </p>
*
* @param listClustersV2Request
* @param 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.
* @return A Java Future containing the result of the ListClustersV2 operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListClustersV2
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClustersV2" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListClustersV2Result> listClustersV2Async(ListClustersV2Request listClustersV2Request,
com.amazonaws.handlers.AsyncHandler<ListClustersV2Request, ListClustersV2Result> asyncHandler);
/**
* <p>
* Returns a list of all the MSK configurations in this Region.
* </p>
*
* @param listConfigurationRevisionsRequest
* @return A Java Future containing the result of the ListConfigurationRevisions operation returned by the service.
* @sample AWSKafkaAsync.ListConfigurationRevisions
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisions"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<ListConfigurationRevisionsResult> listConfigurationRevisionsAsync(
ListConfigurationRevisionsRequest listConfigurationRevisionsRequest);
/**
* <p>
* Returns a list of all the MSK configurations in this Region.
* </p>
*
* @param listConfigurationRevisionsRequest
* @param 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.
* @return A Java Future containing the result of the ListConfigurationRevisions operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListConfigurationRevisions
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisions"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<ListConfigurationRevisionsResult> listConfigurationRevisionsAsync(
ListConfigurationRevisionsRequest listConfigurationRevisionsRequest,
com.amazonaws.handlers.AsyncHandler<ListConfigurationRevisionsRequest, ListConfigurationRevisionsResult> asyncHandler);
/**
* <p>
* Returns a list of all the MSK configurations in this Region.
* </p>
*
* @param listConfigurationsRequest
* @return A Java Future containing the result of the ListConfigurations operation returned by the service.
* @sample AWSKafkaAsync.ListConfigurations
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurations" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListConfigurationsResult> listConfigurationsAsync(ListConfigurationsRequest listConfigurationsRequest);
/**
* <p>
* Returns a list of all the MSK configurations in this Region.
* </p>
*
* @param listConfigurationsRequest
* @param 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.
* @return A Java Future containing the result of the ListConfigurations operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListConfigurations
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurations" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListConfigurationsResult> listConfigurationsAsync(ListConfigurationsRequest listConfigurationsRequest,
com.amazonaws.handlers.AsyncHandler<ListConfigurationsRequest, ListConfigurationsResult> asyncHandler);
/**
* <p>
* Returns a list of Apache Kafka versions.
* </p>
*
* @param listKafkaVersionsRequest
* @return A Java Future containing the result of the ListKafkaVersions operation returned by the service.
* @sample AWSKafkaAsync.ListKafkaVersions
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListKafkaVersions" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListKafkaVersionsResult> listKafkaVersionsAsync(ListKafkaVersionsRequest listKafkaVersionsRequest);
/**
* <p>
* Returns a list of Apache Kafka versions.
* </p>
*
* @param listKafkaVersionsRequest
* @param 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.
* @return A Java Future containing the result of the ListKafkaVersions operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListKafkaVersions
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListKafkaVersions" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListKafkaVersionsResult> listKafkaVersionsAsync(ListKafkaVersionsRequest listKafkaVersionsRequest,
com.amazonaws.handlers.AsyncHandler<ListKafkaVersionsRequest, ListKafkaVersionsResult> asyncHandler);
/**
* <p>
* Returns a list of the broker nodes in the cluster.
* </p>
*
* @param listNodesRequest
* @return A Java Future containing the result of the ListNodes operation returned by the service.
* @sample AWSKafkaAsync.ListNodes
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodes" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListNodesResult> listNodesAsync(ListNodesRequest listNodesRequest);
/**
* <p>
* Returns a list of the broker nodes in the cluster.
* </p>
*
* @param listNodesRequest
* @param 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.
* @return A Java Future containing the result of the ListNodes operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListNodes
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodes" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListNodesResult> listNodesAsync(ListNodesRequest listNodesRequest,
com.amazonaws.handlers.AsyncHandler<ListNodesRequest, ListNodesResult> asyncHandler);
/**
* <p>
* Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
* </p>
*
* @param listScramSecretsRequest
* @return A Java Future containing the result of the ListScramSecrets operation returned by the service.
* @sample AWSKafkaAsync.ListScramSecrets
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListScramSecrets" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListScramSecretsResult> listScramSecretsAsync(ListScramSecretsRequest listScramSecretsRequest);
/**
* <p>
* Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
* </p>
*
* @param listScramSecretsRequest
* @param 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.
* @return A Java Future containing the result of the ListScramSecrets operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListScramSecrets
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListScramSecrets" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListScramSecretsResult> listScramSecretsAsync(ListScramSecretsRequest listScramSecretsRequest,
com.amazonaws.handlers.AsyncHandler<ListScramSecretsRequest, ListScramSecretsResult> asyncHandler);
/**
* <p>
* Returns a list of the tags associated with the specified resource.
* </p>
*
* @param listTagsForResourceRequest
* @return A Java Future containing the result of the ListTagsForResource operation returned by the service.
* @sample AWSKafkaAsync.ListTagsForResource
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResource" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest);
/**
* <p>
* Returns a list of the tags associated with the specified resource.
* </p>
*
* @param listTagsForResourceRequest
* @param 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.
* @return A Java Future containing the result of the ListTagsForResource operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListTagsForResource
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResource" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest,
com.amazonaws.handlers.AsyncHandler<ListTagsForResourceRequest, ListTagsForResourceResult> asyncHandler);
/**
* <p>
* Returns a list of all the VPC connections in this Region.
* </p>
*
* @param listVpcConnectionsRequest
* @return A Java Future containing the result of the ListVpcConnections operation returned by the service.
* @sample AWSKafkaAsync.ListVpcConnections
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListVpcConnections" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListVpcConnectionsResult> listVpcConnectionsAsync(ListVpcConnectionsRequest listVpcConnectionsRequest);
/**
* <p>
* Returns a list of all the VPC connections in this Region.
* </p>
*
* @param listVpcConnectionsRequest
* @param 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.
* @return A Java Future containing the result of the ListVpcConnections operation returned by the service.
* @sample AWSKafkaAsyncHandler.ListVpcConnections
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListVpcConnections" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<ListVpcConnectionsResult> listVpcConnectionsAsync(ListVpcConnectionsRequest listVpcConnectionsRequest,
com.amazonaws.handlers.AsyncHandler<ListVpcConnectionsRequest, ListVpcConnectionsResult> asyncHandler);
/**
* <p>
* Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
* </p>
*
* @param putClusterPolicyRequest
* @return A Java Future containing the result of the PutClusterPolicy operation returned by the service.
* @sample AWSKafkaAsync.PutClusterPolicy
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/PutClusterPolicy" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<PutClusterPolicyResult> putClusterPolicyAsync(PutClusterPolicyRequest putClusterPolicyRequest);
/**
* <p>
* Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.
* </p>
*
* @param putClusterPolicyRequest
* @param 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.
* @return A Java Future containing the result of the PutClusterPolicy operation returned by the service.
* @sample AWSKafkaAsyncHandler.PutClusterPolicy
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/PutClusterPolicy" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<PutClusterPolicyResult> putClusterPolicyAsync(PutClusterPolicyRequest putClusterPolicyRequest,
com.amazonaws.handlers.AsyncHandler<PutClusterPolicyRequest, PutClusterPolicyResult> asyncHandler);
/**
* Reboots brokers.
*
* @param rebootBrokerRequest
* Reboots a node.
* @return A Java Future containing the result of the RebootBroker operation returned by the service.
* @sample AWSKafkaAsync.RebootBroker
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/RebootBroker" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<RebootBrokerResult> rebootBrokerAsync(RebootBrokerRequest rebootBrokerRequest);
/**
* Reboots brokers.
*
* @param rebootBrokerRequest
* Reboots a node.
* @param 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.
* @return A Java Future containing the result of the RebootBroker operation returned by the service.
* @sample AWSKafkaAsyncHandler.RebootBroker
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/RebootBroker" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<RebootBrokerResult> rebootBrokerAsync(RebootBrokerRequest rebootBrokerRequest,
com.amazonaws.handlers.AsyncHandler<RebootBrokerRequest, RebootBrokerResult> asyncHandler);
/**
* <p>
* Returns empty response.
* </p>
*
* @param rejectClientVpcConnectionRequest
* @return A Java Future containing the result of the RejectClientVpcConnection operation returned by the service.
* @sample AWSKafkaAsync.RejectClientVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/RejectClientVpcConnection"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<RejectClientVpcConnectionResult> rejectClientVpcConnectionAsync(
RejectClientVpcConnectionRequest rejectClientVpcConnectionRequest);
/**
* <p>
* Returns empty response.
* </p>
*
* @param rejectClientVpcConnectionRequest
* @param 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.
* @return A Java Future containing the result of the RejectClientVpcConnection operation returned by the service.
* @sample AWSKafkaAsyncHandler.RejectClientVpcConnection
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/RejectClientVpcConnection"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<RejectClientVpcConnectionResult> rejectClientVpcConnectionAsync(
RejectClientVpcConnectionRequest rejectClientVpcConnectionRequest,
com.amazonaws.handlers.AsyncHandler<RejectClientVpcConnectionRequest, RejectClientVpcConnectionResult> asyncHandler);
/**
* <p>
* Adds tags to the specified MSK resource.
* </p>
*
* @param tagResourceRequest
* @return A Java Future containing the result of the TagResource operation returned by the service.
* @sample AWSKafkaAsync.TagResource
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResource" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<TagResourceResult> tagResourceAsync(TagResourceRequest tagResourceRequest);
/**
* <p>
* Adds tags to the specified MSK resource.
* </p>
*
* @param tagResourceRequest
* @param 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.
* @return A Java Future containing the result of the TagResource operation returned by the service.
* @sample AWSKafkaAsyncHandler.TagResource
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResource" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<TagResourceResult> tagResourceAsync(TagResourceRequest tagResourceRequest,
com.amazonaws.handlers.AsyncHandler<TagResourceRequest, TagResourceResult> asyncHandler);
/**
* <p>
* Removes the tags associated with the keys that are provided in the query.
* </p>
*
* @param untagResourceRequest
* @return A Java Future containing the result of the UntagResource operation returned by the service.
* @sample AWSKafkaAsync.UntagResource
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResource" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest untagResourceRequest);
/**
* <p>
* Removes the tags associated with the keys that are provided in the query.
* </p>
*
* @param untagResourceRequest
* @param 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.
* @return A Java Future containing the result of the UntagResource operation returned by the service.
* @sample AWSKafkaAsyncHandler.UntagResource
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResource" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest untagResourceRequest,
com.amazonaws.handlers.AsyncHandler<UntagResourceRequest, UntagResourceResult> asyncHandler);
/**
* <p>
* Updates the number of broker nodes in the cluster.
* </p>
*
* @param updateBrokerCountRequest
* @return A Java Future containing the result of the UpdateBrokerCount operation returned by the service.
* @sample AWSKafkaAsync.UpdateBrokerCount
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerCount" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateBrokerCountResult> updateBrokerCountAsync(UpdateBrokerCountRequest updateBrokerCountRequest);
/**
* <p>
* Updates the number of broker nodes in the cluster.
* </p>
*
* @param updateBrokerCountRequest
* @param 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.
* @return A Java Future containing the result of the UpdateBrokerCount operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateBrokerCount
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerCount" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateBrokerCountResult> updateBrokerCountAsync(UpdateBrokerCountRequest updateBrokerCountRequest,
com.amazonaws.handlers.AsyncHandler<UpdateBrokerCountRequest, UpdateBrokerCountResult> asyncHandler);
/**
* <p>
* Updates the EBS storage associated with MSK brokers.
* </p>
*
* @param updateBrokerStorageRequest
* @return A Java Future containing the result of the UpdateBrokerStorage operation returned by the service.
* @sample AWSKafkaAsync.UpdateBrokerStorage
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorage" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateBrokerStorageResult> updateBrokerStorageAsync(UpdateBrokerStorageRequest updateBrokerStorageRequest);
/**
* <p>
* Updates the EBS storage associated with MSK brokers.
* </p>
*
* @param updateBrokerStorageRequest
* @param 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.
* @return A Java Future containing the result of the UpdateBrokerStorage operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateBrokerStorage
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorage" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateBrokerStorageResult> updateBrokerStorageAsync(UpdateBrokerStorageRequest updateBrokerStorageRequest,
com.amazonaws.handlers.AsyncHandler<UpdateBrokerStorageRequest, UpdateBrokerStorageResult> asyncHandler);
/**
* <p>
* Updates EC2 instance type.
* </p>
*
* @param updateBrokerTypeRequest
* @return A Java Future containing the result of the UpdateBrokerType operation returned by the service.
* @sample AWSKafkaAsync.UpdateBrokerType
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerType" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateBrokerTypeResult> updateBrokerTypeAsync(UpdateBrokerTypeRequest updateBrokerTypeRequest);
/**
* <p>
* Updates EC2 instance type.
* </p>
*
* @param updateBrokerTypeRequest
* @param 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.
* @return A Java Future containing the result of the UpdateBrokerType operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateBrokerType
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerType" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateBrokerTypeResult> updateBrokerTypeAsync(UpdateBrokerTypeRequest updateBrokerTypeRequest,
com.amazonaws.handlers.AsyncHandler<UpdateBrokerTypeRequest, UpdateBrokerTypeResult> asyncHandler);
/**
* <p>
* Updates the cluster with the configuration that is specified in the request body.
* </p>
*
* @param updateClusterConfigurationRequest
* @return A Java Future containing the result of the UpdateClusterConfiguration operation returned by the service.
* @sample AWSKafkaAsync.UpdateClusterConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfiguration"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<UpdateClusterConfigurationResult> updateClusterConfigurationAsync(
UpdateClusterConfigurationRequest updateClusterConfigurationRequest);
/**
* <p>
* Updates the cluster with the configuration that is specified in the request body.
* </p>
*
* @param updateClusterConfigurationRequest
* @param 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.
* @return A Java Future containing the result of the UpdateClusterConfiguration operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateClusterConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfiguration"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<UpdateClusterConfigurationResult> updateClusterConfigurationAsync(
UpdateClusterConfigurationRequest updateClusterConfigurationRequest,
com.amazonaws.handlers.AsyncHandler<UpdateClusterConfigurationRequest, UpdateClusterConfigurationResult> asyncHandler);
/**
* <p>
* Updates the Apache Kafka version for the cluster.
* </p>
*
* @param updateClusterKafkaVersionRequest
* @return A Java Future containing the result of the UpdateClusterKafkaVersion operation returned by the service.
* @sample AWSKafkaAsync.UpdateClusterKafkaVersion
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterKafkaVersion"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<UpdateClusterKafkaVersionResult> updateClusterKafkaVersionAsync(
UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest);
/**
* <p>
* Updates the Apache Kafka version for the cluster.
* </p>
*
* @param updateClusterKafkaVersionRequest
* @param 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.
* @return A Java Future containing the result of the UpdateClusterKafkaVersion operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateClusterKafkaVersion
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterKafkaVersion"
* target="_top">AWS API Documentation</a>
*/
java.util.concurrent.Future<UpdateClusterKafkaVersionResult> updateClusterKafkaVersionAsync(
UpdateClusterKafkaVersionRequest updateClusterKafkaVersionRequest,
com.amazonaws.handlers.AsyncHandler<UpdateClusterKafkaVersionRequest, UpdateClusterKafkaVersionResult> asyncHandler);
/**
* <p>
* Updates an MSK configuration.
* </p>
*
* @param updateConfigurationRequest
* @return A Java Future containing the result of the UpdateConfiguration operation returned by the service.
* @sample AWSKafkaAsync.UpdateConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateConfiguration" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateConfigurationResult> updateConfigurationAsync(UpdateConfigurationRequest updateConfigurationRequest);
/**
* <p>
* Updates an MSK configuration.
* </p>
*
* @param updateConfigurationRequest
* @param 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.
* @return A Java Future containing the result of the UpdateConfiguration operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateConfiguration
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateConfiguration" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateConfigurationResult> updateConfigurationAsync(UpdateConfigurationRequest updateConfigurationRequest,
com.amazonaws.handlers.AsyncHandler<UpdateConfigurationRequest, UpdateConfigurationResult> asyncHandler);
/**
* <p>
* Updates the cluster's connectivity configuration.
* </p>
*
* @param updateConnectivityRequest
* Request body for UpdateConnectivity.
* @return A Java Future containing the result of the UpdateConnectivity operation returned by the service.
* @sample AWSKafkaAsync.UpdateConnectivity
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateConnectivity" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateConnectivityResult> updateConnectivityAsync(UpdateConnectivityRequest updateConnectivityRequest);
/**
* <p>
* Updates the cluster's connectivity configuration.
* </p>
*
* @param updateConnectivityRequest
* Request body for UpdateConnectivity.
* @param 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.
* @return A Java Future containing the result of the UpdateConnectivity operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateConnectivity
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateConnectivity" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateConnectivityResult> updateConnectivityAsync(UpdateConnectivityRequest updateConnectivityRequest,
com.amazonaws.handlers.AsyncHandler<UpdateConnectivityRequest, UpdateConnectivityResult> asyncHandler);
/**
* <p>
* 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.
* </p>
*
* @param updateMonitoringRequest
* Request body for UpdateMonitoring.
* @return A Java Future containing the result of the UpdateMonitoring operation returned by the service.
* @sample AWSKafkaAsync.UpdateMonitoring
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateMonitoring" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateMonitoringResult> updateMonitoringAsync(UpdateMonitoringRequest updateMonitoringRequest);
/**
* <p>
* 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.
* </p>
*
* @param updateMonitoringRequest
* Request body for UpdateMonitoring.
* @param 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.
* @return A Java Future containing the result of the UpdateMonitoring operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateMonitoring
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateMonitoring" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateMonitoringResult> updateMonitoringAsync(UpdateMonitoringRequest updateMonitoringRequest,
com.amazonaws.handlers.AsyncHandler<UpdateMonitoringRequest, UpdateMonitoringResult> asyncHandler);
/**
* <p>
* Updates the security settings for the cluster. You can use this operation to specify encryption and
* authentication on existing clusters.
* </p>
*
* @param updateSecurityRequest
* @return A Java Future containing the result of the UpdateSecurity operation returned by the service.
* @sample AWSKafkaAsync.UpdateSecurity
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateSecurity" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateSecurityResult> updateSecurityAsync(UpdateSecurityRequest updateSecurityRequest);
/**
* <p>
* Updates the security settings for the cluster. You can use this operation to specify encryption and
* authentication on existing clusters.
* </p>
*
* @param updateSecurityRequest
* @param 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.
* @return A Java Future containing the result of the UpdateSecurity operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateSecurity
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateSecurity" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateSecurityResult> updateSecurityAsync(UpdateSecurityRequest updateSecurityRequest,
com.amazonaws.handlers.AsyncHandler<UpdateSecurityRequest, UpdateSecurityResult> asyncHandler);
/**
* Updates cluster broker volume size (or) sets cluster storage mode to TIERED.
*
* @param updateStorageRequest
* <p>
* Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
* </p>
* @return A Java Future containing the result of the UpdateStorage operation returned by the service.
* @sample AWSKafkaAsync.UpdateStorage
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateStorage" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateStorageResult> updateStorageAsync(UpdateStorageRequest updateStorageRequest);
/**
* Updates cluster broker volume size (or) sets cluster storage mode to TIERED.
*
* @param updateStorageRequest
* <p>
* Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
* </p>
* @param 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.
* @return A Java Future containing the result of the UpdateStorage operation returned by the service.
* @sample AWSKafkaAsyncHandler.UpdateStorage
* @see <a href="http://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateStorage" target="_top">AWS API
* Documentation</a>
*/
java.util.concurrent.Future<UpdateStorageResult> updateStorageAsync(UpdateStorageRequest updateStorageRequest,
com.amazonaws.handlers.AsyncHandler<UpdateStorageRequest, UpdateStorageResult> asyncHandler);
}