AWS SDK for C++

AWS SDK for C++ Version 1.11.440

Loading...
Searching...
No Matches
Public Types | Public Member Functions | Static Public Member Functions | Friends | List of all members
Aws::Kafka::KafkaClient Class Reference

#include <KafkaClient.h>

Inheritance diagram for Aws::Kafka::KafkaClient:
[legend]

Public Types

 
 
 

Public Types inherited from Aws::Client::AWSJsonClient

 

Public Member Functions

 KafkaClient (const Aws::Kafka::KafkaClientConfiguration &clientConfiguration=Aws::Kafka::KafkaClientConfiguration(), std::shared_ptr< KafkaEndpointProviderBase > endpointProvider=nullptr)
 
 KafkaClient (const Aws::Auth::AWSCredentials &credentials, std::shared_ptr< KafkaEndpointProviderBase > endpointProvider=nullptr, const Aws::Kafka::KafkaClientConfiguration &clientConfiguration=Aws::Kafka::KafkaClientConfiguration())
 
 KafkaClient (const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, std::shared_ptr< KafkaEndpointProviderBase > endpointProvider=nullptr, const Aws::Kafka::KafkaClientConfiguration &clientConfiguration=Aws::Kafka::KafkaClientConfiguration())
 
 KafkaClient (const Aws::Client::ClientConfiguration &clientConfiguration)
 
 KafkaClient (const Aws::Auth::AWSCredentials &credentials, const Aws::Client::ClientConfiguration &clientConfiguration)
 
 KafkaClient (const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &credentialsProvider, const Aws::Client::ClientConfiguration &clientConfiguration)
 
virtual ~KafkaClient ()
 
 
template<typename BatchAssociateScramSecretRequestT = Model::BatchAssociateScramSecretRequest>
Model::BatchAssociateScramSecretOutcomeCallable BatchAssociateScramSecretCallable (const BatchAssociateScramSecretRequestT &request) const
 
template<typename BatchAssociateScramSecretRequestT = Model::BatchAssociateScramSecretRequest>
void BatchAssociateScramSecretAsync (const BatchAssociateScramSecretRequestT &request, const BatchAssociateScramSecretResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename BatchDisassociateScramSecretRequestT = Model::BatchDisassociateScramSecretRequest>
Model::BatchDisassociateScramSecretOutcomeCallable BatchDisassociateScramSecretCallable (const BatchDisassociateScramSecretRequestT &request) const
 
template<typename BatchDisassociateScramSecretRequestT = Model::BatchDisassociateScramSecretRequest>
void BatchDisassociateScramSecretAsync (const BatchDisassociateScramSecretRequestT &request, const BatchDisassociateScramSecretResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename CreateClusterRequestT = Model::CreateClusterRequest>
Model::CreateClusterOutcomeCallable CreateClusterCallable (const CreateClusterRequestT &request) const
 
template<typename CreateClusterRequestT = Model::CreateClusterRequest>
void CreateClusterAsync (const CreateClusterRequestT &request, const CreateClusterResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename CreateClusterV2RequestT = Model::CreateClusterV2Request>
Model::CreateClusterV2OutcomeCallable CreateClusterV2Callable (const CreateClusterV2RequestT &request) const
 
template<typename CreateClusterV2RequestT = Model::CreateClusterV2Request>
void CreateClusterV2Async (const CreateClusterV2RequestT &request, const CreateClusterV2ResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename CreateConfigurationRequestT = Model::CreateConfigurationRequest>
Model::CreateConfigurationOutcomeCallable CreateConfigurationCallable (const CreateConfigurationRequestT &request) const
 
template<typename CreateConfigurationRequestT = Model::CreateConfigurationRequest>
void CreateConfigurationAsync (const CreateConfigurationRequestT &request, const CreateConfigurationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename CreateReplicatorRequestT = Model::CreateReplicatorRequest>
Model::CreateReplicatorOutcomeCallable CreateReplicatorCallable (const CreateReplicatorRequestT &request) const
 
template<typename CreateReplicatorRequestT = Model::CreateReplicatorRequest>
void CreateReplicatorAsync (const CreateReplicatorRequestT &request, const CreateReplicatorResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename CreateVpcConnectionRequestT = Model::CreateVpcConnectionRequest>
Model::CreateVpcConnectionOutcomeCallable CreateVpcConnectionCallable (const CreateVpcConnectionRequestT &request) const
 
template<typename CreateVpcConnectionRequestT = Model::CreateVpcConnectionRequest>
void CreateVpcConnectionAsync (const CreateVpcConnectionRequestT &request, const CreateVpcConnectionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DeleteClusterRequestT = Model::DeleteClusterRequest>
Model::DeleteClusterOutcomeCallable DeleteClusterCallable (const DeleteClusterRequestT &request) const
 
template<typename DeleteClusterRequestT = Model::DeleteClusterRequest>
void DeleteClusterAsync (const DeleteClusterRequestT &request, const DeleteClusterResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DeleteClusterPolicyRequestT = Model::DeleteClusterPolicyRequest>
Model::DeleteClusterPolicyOutcomeCallable DeleteClusterPolicyCallable (const DeleteClusterPolicyRequestT &request) const
 
template<typename DeleteClusterPolicyRequestT = Model::DeleteClusterPolicyRequest>
void DeleteClusterPolicyAsync (const DeleteClusterPolicyRequestT &request, const DeleteClusterPolicyResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DeleteConfigurationRequestT = Model::DeleteConfigurationRequest>
Model::DeleteConfigurationOutcomeCallable DeleteConfigurationCallable (const DeleteConfigurationRequestT &request) const
 
template<typename DeleteConfigurationRequestT = Model::DeleteConfigurationRequest>
void DeleteConfigurationAsync (const DeleteConfigurationRequestT &request, const DeleteConfigurationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DeleteReplicatorRequestT = Model::DeleteReplicatorRequest>
Model::DeleteReplicatorOutcomeCallable DeleteReplicatorCallable (const DeleteReplicatorRequestT &request) const
 
template<typename DeleteReplicatorRequestT = Model::DeleteReplicatorRequest>
void DeleteReplicatorAsync (const DeleteReplicatorRequestT &request, const DeleteReplicatorResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DeleteVpcConnectionRequestT = Model::DeleteVpcConnectionRequest>
Model::DeleteVpcConnectionOutcomeCallable DeleteVpcConnectionCallable (const DeleteVpcConnectionRequestT &request) const
 
template<typename DeleteVpcConnectionRequestT = Model::DeleteVpcConnectionRequest>
void DeleteVpcConnectionAsync (const DeleteVpcConnectionRequestT &request, const DeleteVpcConnectionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeClusterRequestT = Model::DescribeClusterRequest>
Model::DescribeClusterOutcomeCallable DescribeClusterCallable (const DescribeClusterRequestT &request) const
 
template<typename DescribeClusterRequestT = Model::DescribeClusterRequest>
void DescribeClusterAsync (const DescribeClusterRequestT &request, const DescribeClusterResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeClusterOperationRequestT = Model::DescribeClusterOperationRequest>
Model::DescribeClusterOperationOutcomeCallable DescribeClusterOperationCallable (const DescribeClusterOperationRequestT &request) const
 
template<typename DescribeClusterOperationRequestT = Model::DescribeClusterOperationRequest>
void DescribeClusterOperationAsync (const DescribeClusterOperationRequestT &request, const DescribeClusterOperationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeClusterOperationV2RequestT = Model::DescribeClusterOperationV2Request>
Model::DescribeClusterOperationV2OutcomeCallable DescribeClusterOperationV2Callable (const DescribeClusterOperationV2RequestT &request) const
 
template<typename DescribeClusterOperationV2RequestT = Model::DescribeClusterOperationV2Request>
void DescribeClusterOperationV2Async (const DescribeClusterOperationV2RequestT &request, const DescribeClusterOperationV2ResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeClusterV2RequestT = Model::DescribeClusterV2Request>
Model::DescribeClusterV2OutcomeCallable DescribeClusterV2Callable (const DescribeClusterV2RequestT &request) const
 
template<typename DescribeClusterV2RequestT = Model::DescribeClusterV2Request>
void DescribeClusterV2Async (const DescribeClusterV2RequestT &request, const DescribeClusterV2ResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeConfigurationRequestT = Model::DescribeConfigurationRequest>
Model::DescribeConfigurationOutcomeCallable DescribeConfigurationCallable (const DescribeConfigurationRequestT &request) const
 
template<typename DescribeConfigurationRequestT = Model::DescribeConfigurationRequest>
void DescribeConfigurationAsync (const DescribeConfigurationRequestT &request, const DescribeConfigurationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeConfigurationRevisionRequestT = Model::DescribeConfigurationRevisionRequest>
Model::DescribeConfigurationRevisionOutcomeCallable DescribeConfigurationRevisionCallable (const DescribeConfigurationRevisionRequestT &request) const
 
template<typename DescribeConfigurationRevisionRequestT = Model::DescribeConfigurationRevisionRequest>
void DescribeConfigurationRevisionAsync (const DescribeConfigurationRevisionRequestT &request, const DescribeConfigurationRevisionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeReplicatorRequestT = Model::DescribeReplicatorRequest>
Model::DescribeReplicatorOutcomeCallable DescribeReplicatorCallable (const DescribeReplicatorRequestT &request) const
 
template<typename DescribeReplicatorRequestT = Model::DescribeReplicatorRequest>
void DescribeReplicatorAsync (const DescribeReplicatorRequestT &request, const DescribeReplicatorResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename DescribeVpcConnectionRequestT = Model::DescribeVpcConnectionRequest>
Model::DescribeVpcConnectionOutcomeCallable DescribeVpcConnectionCallable (const DescribeVpcConnectionRequestT &request) const
 
template<typename DescribeVpcConnectionRequestT = Model::DescribeVpcConnectionRequest>
void DescribeVpcConnectionAsync (const DescribeVpcConnectionRequestT &request, const DescribeVpcConnectionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename GetBootstrapBrokersRequestT = Model::GetBootstrapBrokersRequest>
Model::GetBootstrapBrokersOutcomeCallable GetBootstrapBrokersCallable (const GetBootstrapBrokersRequestT &request) const
 
template<typename GetBootstrapBrokersRequestT = Model::GetBootstrapBrokersRequest>
void GetBootstrapBrokersAsync (const GetBootstrapBrokersRequestT &request, const GetBootstrapBrokersResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename GetClusterPolicyRequestT = Model::GetClusterPolicyRequest>
Model::GetClusterPolicyOutcomeCallable GetClusterPolicyCallable (const GetClusterPolicyRequestT &request) const
 
template<typename GetClusterPolicyRequestT = Model::GetClusterPolicyRequest>
void GetClusterPolicyAsync (const GetClusterPolicyRequestT &request, const GetClusterPolicyResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename GetCompatibleKafkaVersionsRequestT = Model::GetCompatibleKafkaVersionsRequest>
Model::GetCompatibleKafkaVersionsOutcomeCallable GetCompatibleKafkaVersionsCallable (const GetCompatibleKafkaVersionsRequestT &request={}) const
 
template<typename GetCompatibleKafkaVersionsRequestT = Model::GetCompatibleKafkaVersionsRequest>
void GetCompatibleKafkaVersionsAsync (const GetCompatibleKafkaVersionsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const GetCompatibleKafkaVersionsRequestT &request={}) const
 
 
template<typename ListClientVpcConnectionsRequestT = Model::ListClientVpcConnectionsRequest>
Model::ListClientVpcConnectionsOutcomeCallable ListClientVpcConnectionsCallable (const ListClientVpcConnectionsRequestT &request) const
 
template<typename ListClientVpcConnectionsRequestT = Model::ListClientVpcConnectionsRequest>
void ListClientVpcConnectionsAsync (const ListClientVpcConnectionsRequestT &request, const ListClientVpcConnectionsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListClusterOperationsRequestT = Model::ListClusterOperationsRequest>
Model::ListClusterOperationsOutcomeCallable ListClusterOperationsCallable (const ListClusterOperationsRequestT &request) const
 
template<typename ListClusterOperationsRequestT = Model::ListClusterOperationsRequest>
void ListClusterOperationsAsync (const ListClusterOperationsRequestT &request, const ListClusterOperationsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListClusterOperationsV2RequestT = Model::ListClusterOperationsV2Request>
Model::ListClusterOperationsV2OutcomeCallable ListClusterOperationsV2Callable (const ListClusterOperationsV2RequestT &request) const
 
template<typename ListClusterOperationsV2RequestT = Model::ListClusterOperationsV2Request>
void ListClusterOperationsV2Async (const ListClusterOperationsV2RequestT &request, const ListClusterOperationsV2ResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListClustersRequestT = Model::ListClustersRequest>
Model::ListClustersOutcomeCallable ListClustersCallable (const ListClustersRequestT &request={}) const
 
template<typename ListClustersRequestT = Model::ListClustersRequest>
void ListClustersAsync (const ListClustersResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListClustersRequestT &request={}) const
 
 
template<typename ListClustersV2RequestT = Model::ListClustersV2Request>
Model::ListClustersV2OutcomeCallable ListClustersV2Callable (const ListClustersV2RequestT &request={}) const
 
template<typename ListClustersV2RequestT = Model::ListClustersV2Request>
void ListClustersV2Async (const ListClustersV2ResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListClustersV2RequestT &request={}) const
 
 
template<typename ListConfigurationRevisionsRequestT = Model::ListConfigurationRevisionsRequest>
Model::ListConfigurationRevisionsOutcomeCallable ListConfigurationRevisionsCallable (const ListConfigurationRevisionsRequestT &request) const
 
template<typename ListConfigurationRevisionsRequestT = Model::ListConfigurationRevisionsRequest>
void ListConfigurationRevisionsAsync (const ListConfigurationRevisionsRequestT &request, const ListConfigurationRevisionsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListConfigurationsRequestT = Model::ListConfigurationsRequest>
Model::ListConfigurationsOutcomeCallable ListConfigurationsCallable (const ListConfigurationsRequestT &request={}) const
 
template<typename ListConfigurationsRequestT = Model::ListConfigurationsRequest>
void ListConfigurationsAsync (const ListConfigurationsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListConfigurationsRequestT &request={}) const
 
 
template<typename ListKafkaVersionsRequestT = Model::ListKafkaVersionsRequest>
Model::ListKafkaVersionsOutcomeCallable ListKafkaVersionsCallable (const ListKafkaVersionsRequestT &request={}) const
 
template<typename ListKafkaVersionsRequestT = Model::ListKafkaVersionsRequest>
void ListKafkaVersionsAsync (const ListKafkaVersionsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListKafkaVersionsRequestT &request={}) const
 
 
template<typename ListNodesRequestT = Model::ListNodesRequest>
Model::ListNodesOutcomeCallable ListNodesCallable (const ListNodesRequestT &request) const
 
template<typename ListNodesRequestT = Model::ListNodesRequest>
void ListNodesAsync (const ListNodesRequestT &request, const ListNodesResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListReplicatorsRequestT = Model::ListReplicatorsRequest>
Model::ListReplicatorsOutcomeCallable ListReplicatorsCallable (const ListReplicatorsRequestT &request={}) const
 
template<typename ListReplicatorsRequestT = Model::ListReplicatorsRequest>
void ListReplicatorsAsync (const ListReplicatorsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListReplicatorsRequestT &request={}) const
 
 
template<typename ListScramSecretsRequestT = Model::ListScramSecretsRequest>
Model::ListScramSecretsOutcomeCallable ListScramSecretsCallable (const ListScramSecretsRequestT &request) const
 
template<typename ListScramSecretsRequestT = Model::ListScramSecretsRequest>
void ListScramSecretsAsync (const ListScramSecretsRequestT &request, const ListScramSecretsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListTagsForResourceRequestT = Model::ListTagsForResourceRequest>
Model::ListTagsForResourceOutcomeCallable ListTagsForResourceCallable (const ListTagsForResourceRequestT &request) const
 
template<typename ListTagsForResourceRequestT = Model::ListTagsForResourceRequest>
void ListTagsForResourceAsync (const ListTagsForResourceRequestT &request, const ListTagsForResourceResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename ListVpcConnectionsRequestT = Model::ListVpcConnectionsRequest>
Model::ListVpcConnectionsOutcomeCallable ListVpcConnectionsCallable (const ListVpcConnectionsRequestT &request={}) const
 
template<typename ListVpcConnectionsRequestT = Model::ListVpcConnectionsRequest>
void ListVpcConnectionsAsync (const ListVpcConnectionsResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr, const ListVpcConnectionsRequestT &request={}) const
 
 
template<typename PutClusterPolicyRequestT = Model::PutClusterPolicyRequest>
Model::PutClusterPolicyOutcomeCallable PutClusterPolicyCallable (const PutClusterPolicyRequestT &request) const
 
template<typename PutClusterPolicyRequestT = Model::PutClusterPolicyRequest>
void PutClusterPolicyAsync (const PutClusterPolicyRequestT &request, const PutClusterPolicyResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename RebootBrokerRequestT = Model::RebootBrokerRequest>
Model::RebootBrokerOutcomeCallable RebootBrokerCallable (const RebootBrokerRequestT &request) const
 
template<typename RebootBrokerRequestT = Model::RebootBrokerRequest>
void RebootBrokerAsync (const RebootBrokerRequestT &request, const RebootBrokerResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename RejectClientVpcConnectionRequestT = Model::RejectClientVpcConnectionRequest>
Model::RejectClientVpcConnectionOutcomeCallable RejectClientVpcConnectionCallable (const RejectClientVpcConnectionRequestT &request) const
 
template<typename RejectClientVpcConnectionRequestT = Model::RejectClientVpcConnectionRequest>
void RejectClientVpcConnectionAsync (const RejectClientVpcConnectionRequestT &request, const RejectClientVpcConnectionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename TagResourceRequestT = Model::TagResourceRequest>
Model::TagResourceOutcomeCallable TagResourceCallable (const TagResourceRequestT &request) const
 
template<typename TagResourceRequestT = Model::TagResourceRequest>
void TagResourceAsync (const TagResourceRequestT &request, const TagResourceResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UntagResourceRequestT = Model::UntagResourceRequest>
Model::UntagResourceOutcomeCallable UntagResourceCallable (const UntagResourceRequestT &request) const
 
template<typename UntagResourceRequestT = Model::UntagResourceRequest>
void UntagResourceAsync (const UntagResourceRequestT &request, const UntagResourceResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateBrokerCountRequestT = Model::UpdateBrokerCountRequest>
Model::UpdateBrokerCountOutcomeCallable UpdateBrokerCountCallable (const UpdateBrokerCountRequestT &request) const
 
template<typename UpdateBrokerCountRequestT = Model::UpdateBrokerCountRequest>
void UpdateBrokerCountAsync (const UpdateBrokerCountRequestT &request, const UpdateBrokerCountResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateBrokerStorageRequestT = Model::UpdateBrokerStorageRequest>
Model::UpdateBrokerStorageOutcomeCallable UpdateBrokerStorageCallable (const UpdateBrokerStorageRequestT &request) const
 
template<typename UpdateBrokerStorageRequestT = Model::UpdateBrokerStorageRequest>
void UpdateBrokerStorageAsync (const UpdateBrokerStorageRequestT &request, const UpdateBrokerStorageResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateBrokerTypeRequestT = Model::UpdateBrokerTypeRequest>
Model::UpdateBrokerTypeOutcomeCallable UpdateBrokerTypeCallable (const UpdateBrokerTypeRequestT &request) const
 
template<typename UpdateBrokerTypeRequestT = Model::UpdateBrokerTypeRequest>
void UpdateBrokerTypeAsync (const UpdateBrokerTypeRequestT &request, const UpdateBrokerTypeResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateClusterConfigurationRequestT = Model::UpdateClusterConfigurationRequest>
Model::UpdateClusterConfigurationOutcomeCallable UpdateClusterConfigurationCallable (const UpdateClusterConfigurationRequestT &request) const
 
template<typename UpdateClusterConfigurationRequestT = Model::UpdateClusterConfigurationRequest>
void UpdateClusterConfigurationAsync (const UpdateClusterConfigurationRequestT &request, const UpdateClusterConfigurationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateClusterKafkaVersionRequestT = Model::UpdateClusterKafkaVersionRequest>
Model::UpdateClusterKafkaVersionOutcomeCallable UpdateClusterKafkaVersionCallable (const UpdateClusterKafkaVersionRequestT &request) const
 
template<typename UpdateClusterKafkaVersionRequestT = Model::UpdateClusterKafkaVersionRequest>
void UpdateClusterKafkaVersionAsync (const UpdateClusterKafkaVersionRequestT &request, const UpdateClusterKafkaVersionResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateConfigurationRequestT = Model::UpdateConfigurationRequest>
Model::UpdateConfigurationOutcomeCallable UpdateConfigurationCallable (const UpdateConfigurationRequestT &request) const
 
template<typename UpdateConfigurationRequestT = Model::UpdateConfigurationRequest>
void UpdateConfigurationAsync (const UpdateConfigurationRequestT &request, const UpdateConfigurationResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateConnectivityRequestT = Model::UpdateConnectivityRequest>
Model::UpdateConnectivityOutcomeCallable UpdateConnectivityCallable (const UpdateConnectivityRequestT &request) const
 
template<typename UpdateConnectivityRequestT = Model::UpdateConnectivityRequest>
void UpdateConnectivityAsync (const UpdateConnectivityRequestT &request, const UpdateConnectivityResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateMonitoringRequestT = Model::UpdateMonitoringRequest>
Model::UpdateMonitoringOutcomeCallable UpdateMonitoringCallable (const UpdateMonitoringRequestT &request) const
 
template<typename UpdateMonitoringRequestT = Model::UpdateMonitoringRequest>
void UpdateMonitoringAsync (const UpdateMonitoringRequestT &request, const UpdateMonitoringResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateReplicationInfoRequestT = Model::UpdateReplicationInfoRequest>
Model::UpdateReplicationInfoOutcomeCallable UpdateReplicationInfoCallable (const UpdateReplicationInfoRequestT &request) const
 
template<typename UpdateReplicationInfoRequestT = Model::UpdateReplicationInfoRequest>
void UpdateReplicationInfoAsync (const UpdateReplicationInfoRequestT &request, const UpdateReplicationInfoResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateSecurityRequestT = Model::UpdateSecurityRequest>
Model::UpdateSecurityOutcomeCallable UpdateSecurityCallable (const UpdateSecurityRequestT &request) const
 
template<typename UpdateSecurityRequestT = Model::UpdateSecurityRequest>
void UpdateSecurityAsync (const UpdateSecurityRequestT &request, const UpdateSecurityResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
 
template<typename UpdateStorageRequestT = Model::UpdateStorageRequest>
Model::UpdateStorageOutcomeCallable UpdateStorageCallable (const UpdateStorageRequestT &request) const
 
template<typename UpdateStorageRequestT = Model::UpdateStorageRequest>
void UpdateStorageAsync (const UpdateStorageRequestT &request, const UpdateStorageResponseReceivedHandler &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
void OverrideEndpoint (const Aws::String &endpoint)
 
 

Public Member Functions inherited from Aws::Client::AWSJsonClient

 AWSJsonClient (const Aws::Client::ClientConfiguration &configuration, const std::shared_ptr< Aws::Client::AWSAuthSigner > &signer, const std::shared_ptr< AWSErrorMarshaller > &errorMarshaller)
 
 AWSJsonClient (const Aws::Client::ClientConfiguration &configuration, const std::shared_ptr< Aws::Auth::AWSAuthSignerProvider > &signerProvider, const std::shared_ptr< AWSErrorMarshaller > &errorMarshaller)
 
virtual ~AWSJsonClient ()=default
 

Public Member Functions inherited from Aws::Client::AWSClient

 AWSClient (const Aws::Client::ClientConfiguration &configuration, const std::shared_ptr< Aws::Client::AWSAuthSigner > &signer, const std::shared_ptr< AWSErrorMarshaller > &errorMarshaller)
 
 AWSClient (const Aws::Client::ClientConfiguration &configuration, const std::shared_ptr< Aws::Auth::AWSAuthSignerProvider > &signerProvider, const std::shared_ptr< AWSErrorMarshaller > &errorMarshaller)
 
virtual ~AWSClient ()
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={})
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const Aws::Http::HeaderValueCollection &customizedHeaders, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={})
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const Aws::Http::HeaderValueCollection &customizedHeaders, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={})
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const char *serviceName, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const char *serviceName, const Aws::Http::HeaderValueCollection &customizedHeaders, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={})
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const char *serviceName, const char *signerName, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
Aws::String GeneratePresignedUrl (const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const char *serviceName, const char *signerName, const Aws::Http::HeaderValueCollection &customizedHeaders, long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={})
 
Aws::String GeneratePresignedUrl (const Aws::Endpoint::AWSEndpoint &endpoint, Aws::Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const Aws::Http::HeaderValueCollection &customizedHeaders={}, uint64_t expirationInSeconds=0, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={})
 
Aws::String GeneratePresignedUrl (const Aws::AmazonWebServiceRequest &request, const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const Aws::Http::QueryStringParameterCollection &extraParams=Aws::Http::QueryStringParameterCollection(), long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
Aws::String GeneratePresignedUrl (const Aws::AmazonWebServiceRequest &request, const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const char *serviceName, const char *signerName, const Aws::Http::QueryStringParameterCollection &extraParams=Aws::Http::QueryStringParameterCollection(), long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
Aws::String GeneratePresignedUrl (const Aws::AmazonWebServiceRequest &request, const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const char *serviceName, const Aws::Http::QueryStringParameterCollection &extraParams=Aws::Http::QueryStringParameterCollection(), long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
Aws::String GeneratePresignedUrl (const Aws::AmazonWebServiceRequest &request, const Aws::Http::URI &uri, Aws::Http::HttpMethod method, const char *region, const Aws::Http::QueryStringParameterCollection &extraParams=Aws::Http::QueryStringParameterCollection(), long long expirationInSeconds=0, const std::shared_ptr< Aws::Http::ServiceSpecificParameters > serviceSpecificParameter={}) const
 
const std::shared_ptr< Aws::Http::HttpClient > & GetHttpClient () const
 
 
 
virtual const char * GetServiceClientName () const
 
virtual void SetServiceClientName (const Aws::String &name)
 
void AppendToUserAgent (const Aws::String &valueToAppend)
 

Public Member Functions inherited from Aws::Client::ClientWithAsyncTemplateMethods< KafkaClient >

 
 
 
 
void SubmitAsync (OperationFuncT operationFunc, const RequestT &request, const HandlerT &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
void SubmitAsync (OperationFuncT operationFunc, RequestT &request, const HandlerT &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
void SubmitAsync (OperationFuncT operationFunc, const HandlerT &handler, const std::shared_ptr< const Aws::Client::AsyncCallerContext > &context=nullptr) const
 
auto SubmitCallable (OperationFuncT operationFunc, const RequestT &request) const -> std::future< decltype((static_cast< const AwsServiceClientT * >(nullptr) -> *operationFunc)(request))>
 
auto SubmitCallable (OperationFuncT operationFunc, RequestT &request) const -> std::future< decltype((static_cast< const AwsServiceClientT * >(nullptr) -> *operationFunc)(request))>
 
auto SubmitCallable (OperationFuncT operationFunc) const -> std::future< decltype((static_cast< const AwsServiceClientT * >(nullptr) -> *operationFunc)())>
 

Static Public Member Functions

static const char * GetServiceName ()
 
static const char * GetAllocationTag ()
 

Static Public Member Functions inherited from Aws::Client::ClientWithAsyncTemplateMethods< KafkaClient >

static void ShutdownSdkClient (void *pThis, int64_t timeoutMs=-1)
 

Friends

 

Additional Inherited Members

Protected Member Functions inherited from Aws::Client::AWSJsonClient

virtual AWSError< CoreErrorsBuildAWSError (const std::shared_ptr< Aws::Http::HttpResponse > &response) const override
 
JsonOutcome MakeRequest (const Aws::AmazonWebServiceRequest &request, const Aws::Endpoint::AWSEndpoint &endpoint, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
JsonOutcome MakeRequest (const Aws::Endpoint::AWSEndpoint &endpoint, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
JsonOutcome MakeRequest (const Aws::Http::URI &uri, const Aws::AmazonWebServiceRequest &request, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
JsonOutcome MakeRequest (const Aws::Http::URI &uri, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *requestName="", const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
JsonOutcome MakeEventStreamRequest (std::shared_ptr< Aws::Http::HttpRequest > &request) const
 

Protected Member Functions inherited from Aws::Client::AWSClient

HttpResponseOutcome AttemptExhaustively (const Aws::Http::URI &uri, const Aws::AmazonWebServiceRequest &request, Http::HttpMethod httpMethod, const char *signerName, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
HttpResponseOutcome AttemptExhaustively (const Aws::Http::URI &uri, Http::HttpMethod httpMethod, const char *signerName, const char *requestName="", const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
HttpResponseOutcome AttemptOneRequest (const std::shared_ptr< Http::HttpRequest > &httpRequest, const Aws::AmazonWebServiceRequest &request, const char *signerName, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
HttpResponseOutcome AttemptOneRequest (const std::shared_ptr< Http::HttpRequest > &httpRequest, const char *signerName, const char *requestName="", const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
StreamOutcome MakeRequestWithUnparsedResponse (const Aws::Http::URI &uri, const Aws::AmazonWebServiceRequest &request, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
StreamOutcome MakeRequestWithUnparsedResponse (const Aws::Http::URI &uri, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *requestName="", const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
StreamOutcome MakeRequestWithUnparsedResponse (const Aws::AmazonWebServiceRequest &request, const Aws::Endpoint::AWSEndpoint &endpoint, Http::HttpMethod method=Http::HttpMethod::HTTP_POST, const char *signerName=Aws::Auth::SIGV4_SIGNER, const char *signerRegionOverride=nullptr, const char *signerServiceNameOverride=nullptr) const
 
virtual void BuildHttpRequest (const Aws::AmazonWebServiceRequest &request, const std::shared_ptr< Aws::Http::HttpRequest > &httpRequest) const
 
const std::shared_ptr< AWSErrorMarshaller > & GetErrorMarshaller () const
 
Aws::Client::AWSAuthSignerGetSignerByName (const char *name) const
 
 
std::shared_ptr< Aws::Http::HttpRequestBuildAndSignHttpRequest (const Aws::Http::URI &uri, const Aws::AmazonWebServiceRequest &request, Http::HttpMethod method, const char *signerName) const
 
std::shared_ptr< Aws::Http::HttpResponseMakeHttpRequest (std::shared_ptr< Aws::Http::HttpRequest > &request) const
 

Static Protected Member Functions inherited from Aws::Client::AWSClient

static void AppendRecursionDetectionHeader (std::shared_ptr< Aws::Http::HttpRequest > ioRequest)
 
 
static bool DoesResponseGenerateError (const std::shared_ptr< Aws::Http::HttpResponse > &response)
 

Protected Attributes inherited from Aws::Client::AWSClient

 
 
 
std::atomic< bool > m_isInitialized
 
std::atomic< size_t > m_operationsProcessed
 
std::condition_variable m_shutdownSignal
 
std::mutex m_shutdownMutex
 

Detailed Description

The operations for managing an Amazon MSK cluster.

Definition at line 24 of file KafkaClient.h.

Member Typedef Documentation

◆ BASECLASS

Definition at line 27 of file KafkaClient.h.

◆ ClientConfigurationType

Definition at line 31 of file KafkaClient.h.

◆ EndpointProviderType

Definition at line 32 of file KafkaClient.h.

Constructor & Destructor Documentation

◆ KafkaClient() [1/6]

Aws::Kafka::KafkaClient::KafkaClient ( const Aws::Kafka::KafkaClientConfiguration clientConfiguration = Aws::Kafka::KafkaClientConfiguration(),
std::shared_ptr< KafkaEndpointProviderBase endpointProvider = nullptr 
)

Initializes client to use DefaultCredentialProviderChain, with default http client factory, and optional client config. If client config is not specified, it will be initialized to default values.

◆ KafkaClient() [2/6]

Aws::Kafka::KafkaClient::KafkaClient ( const Aws::Auth::AWSCredentials credentials,
std::shared_ptr< KafkaEndpointProviderBase endpointProvider = nullptr,
const Aws::Kafka::KafkaClientConfiguration clientConfiguration = Aws::Kafka::KafkaClientConfiguration() 
)

Initializes client to use SimpleAWSCredentialsProvider, with default http client factory, and optional client config. If client config is not specified, it will be initialized to default values.

◆ KafkaClient() [3/6]

Aws::Kafka::KafkaClient::KafkaClient ( const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &  credentialsProvider,
std::shared_ptr< KafkaEndpointProviderBase endpointProvider = nullptr,
const Aws::Kafka::KafkaClientConfiguration clientConfiguration = Aws::Kafka::KafkaClientConfiguration() 
)

Initializes client to use specified credentials provider with specified client config. If http client factory is not supplied, the default http client factory will be used

◆ KafkaClient() [4/6]

Aws::Kafka::KafkaClient::KafkaClient ( const Aws::Client::ClientConfiguration clientConfiguration)

Initializes client to use DefaultCredentialProviderChain, with default http client factory, and optional client config. If client config is not specified, it will be initialized to default values.

◆ KafkaClient() [5/6]

Aws::Kafka::KafkaClient::KafkaClient ( const Aws::Auth::AWSCredentials credentials,
const Aws::Client::ClientConfiguration clientConfiguration 
)

Initializes client to use SimpleAWSCredentialsProvider, with default http client factory, and optional client config. If client config is not specified, it will be initialized to default values.

◆ KafkaClient() [6/6]

Aws::Kafka::KafkaClient::KafkaClient ( const std::shared_ptr< Aws::Auth::AWSCredentialsProvider > &  credentialsProvider,
const Aws::Client::ClientConfiguration clientConfiguration 
)

Initializes client to use specified credentials provider with specified client config. If http client factory is not supplied, the default http client factory will be used

◆ ~KafkaClient()

virtual Aws::Kafka::KafkaClient::~KafkaClient ( )
virtual

Member Function Documentation

◆ accessEndpointProvider()

std::shared_ptr< KafkaEndpointProviderBase > & Aws::Kafka::KafkaClient::accessEndpointProvider ( )

◆ BatchAssociateScramSecret()

virtual Model::BatchAssociateScramSecretOutcome Aws::Kafka::KafkaClient::BatchAssociateScramSecret ( const Model::BatchAssociateScramSecretRequest request) const
virtual

Associates one or more Scram Secrets with an Amazon MSK cluster.

See Also:

AWS API Reference

◆ BatchAssociateScramSecretAsync()

template<typename BatchAssociateScramSecretRequestT = Model::BatchAssociateScramSecretRequest>
void Aws::Kafka::KafkaClient::BatchAssociateScramSecretAsync ( const BatchAssociateScramSecretRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for BatchAssociateScramSecret that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 105 of file KafkaClient.h.

◆ BatchAssociateScramSecretCallable()

template<typename BatchAssociateScramSecretRequestT = Model::BatchAssociateScramSecretRequest>
Model::BatchAssociateScramSecretOutcomeCallable Aws::Kafka::KafkaClient::BatchAssociateScramSecretCallable ( const BatchAssociateScramSecretRequestT &  request) const
inline

A Callable wrapper for BatchAssociateScramSecret that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 96 of file KafkaClient.h.

◆ BatchDisassociateScramSecret()

virtual Model::BatchDisassociateScramSecretOutcome Aws::Kafka::KafkaClient::BatchDisassociateScramSecret ( const Model::BatchDisassociateScramSecretRequest request) const
virtual

Disassociates one or more Scram Secrets from an Amazon MSK cluster.

See Also:

AWS API Reference

◆ BatchDisassociateScramSecretAsync()

template<typename BatchDisassociateScramSecretRequestT = Model::BatchDisassociateScramSecretRequest>
void Aws::Kafka::KafkaClient::BatchDisassociateScramSecretAsync ( const BatchDisassociateScramSecretRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for BatchDisassociateScramSecret that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 133 of file KafkaClient.h.

◆ BatchDisassociateScramSecretCallable()

template<typename BatchDisassociateScramSecretRequestT = Model::BatchDisassociateScramSecretRequest>
Model::BatchDisassociateScramSecretOutcomeCallable Aws::Kafka::KafkaClient::BatchDisassociateScramSecretCallable ( const BatchDisassociateScramSecretRequestT &  request) const
inline

A Callable wrapper for BatchDisassociateScramSecret that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 124 of file KafkaClient.h.

◆ CreateCluster()

virtual Model::CreateClusterOutcome Aws::Kafka::KafkaClient::CreateCluster ( const Model::CreateClusterRequest request) const
virtual

Creates a new MSK cluster.

See Also:


AWS API Reference

◆ CreateClusterAsync()

template<typename CreateClusterRequestT = Model::CreateClusterRequest>
void Aws::Kafka::KafkaClient::CreateClusterAsync ( const CreateClusterRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for CreateCluster that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 161 of file KafkaClient.h.

◆ CreateClusterCallable()

template<typename CreateClusterRequestT = Model::CreateClusterRequest>
Model::CreateClusterOutcomeCallable Aws::Kafka::KafkaClient::CreateClusterCallable ( const CreateClusterRequestT &  request) const
inline

A Callable wrapper for CreateCluster that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 152 of file KafkaClient.h.

◆ CreateClusterV2()

virtual Model::CreateClusterV2Outcome Aws::Kafka::KafkaClient::CreateClusterV2 ( const Model::CreateClusterV2Request request) const
virtual

Creates a new MSK cluster.

See Also:


AWS API Reference

◆ CreateClusterV2Async()

template<typename CreateClusterV2RequestT = Model::CreateClusterV2Request>
void Aws::Kafka::KafkaClient::CreateClusterV2Async ( const CreateClusterV2RequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for CreateClusterV2 that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 189 of file KafkaClient.h.

◆ CreateClusterV2Callable()

template<typename CreateClusterV2RequestT = Model::CreateClusterV2Request>
Model::CreateClusterV2OutcomeCallable Aws::Kafka::KafkaClient::CreateClusterV2Callable ( const CreateClusterV2RequestT &  request) const
inline

A Callable wrapper for CreateClusterV2 that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 180 of file KafkaClient.h.

◆ CreateConfiguration()

virtual Model::CreateConfigurationOutcome Aws::Kafka::KafkaClient::CreateConfiguration ( const Model::CreateConfigurationRequest request) const
virtual

Creates a new MSK configuration.

See Also:

AWS API Reference

◆ CreateConfigurationAsync()

template<typename CreateConfigurationRequestT = Model::CreateConfigurationRequest>
void Aws::Kafka::KafkaClient::CreateConfigurationAsync ( const CreateConfigurationRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for CreateConfiguration that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 217 of file KafkaClient.h.

◆ CreateConfigurationCallable()

template<typename CreateConfigurationRequestT = Model::CreateConfigurationRequest>
Model::CreateConfigurationOutcomeCallable Aws::Kafka::KafkaClient::CreateConfigurationCallable ( const CreateConfigurationRequestT &  request) const
inline

A Callable wrapper for CreateConfiguration that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 208 of file KafkaClient.h.

◆ CreateReplicator()

virtual Model::CreateReplicatorOutcome Aws::Kafka::KafkaClient::CreateReplicator ( const Model::CreateReplicatorRequest request) const
virtual

Creates the replicator.

See Also:

AWS API Reference

◆ CreateReplicatorAsync()

template<typename CreateReplicatorRequestT = Model::CreateReplicatorRequest>
void Aws::Kafka::KafkaClient::CreateReplicatorAsync ( const CreateReplicatorRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for CreateReplicator that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 242 of file KafkaClient.h.

◆ CreateReplicatorCallable()

template<typename CreateReplicatorRequestT = Model::CreateReplicatorRequest>
Model::CreateReplicatorOutcomeCallable Aws::Kafka::KafkaClient::CreateReplicatorCallable ( const CreateReplicatorRequestT &  request) const
inline

A Callable wrapper for CreateReplicator that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 233 of file KafkaClient.h.

◆ CreateVpcConnection()

virtual Model::CreateVpcConnectionOutcome Aws::Kafka::KafkaClient::CreateVpcConnection ( const Model::CreateVpcConnectionRequest request) const
virtual

Creates a new MSK VPC connection.

See Also:

AWS API Reference

◆ CreateVpcConnectionAsync()

template<typename CreateVpcConnectionRequestT = Model::CreateVpcConnectionRequest>
void Aws::Kafka::KafkaClient::CreateVpcConnectionAsync ( const CreateVpcConnectionRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for CreateVpcConnection that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 270 of file KafkaClient.h.

◆ CreateVpcConnectionCallable()

template<typename CreateVpcConnectionRequestT = Model::CreateVpcConnectionRequest>
Model::CreateVpcConnectionOutcomeCallable Aws::Kafka::KafkaClient::CreateVpcConnectionCallable ( const CreateVpcConnectionRequestT &  request) const
inline

A Callable wrapper for CreateVpcConnection that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 261 of file KafkaClient.h.

◆ DeleteCluster()

virtual Model::DeleteClusterOutcome Aws::Kafka::KafkaClient::DeleteCluster ( const Model::DeleteClusterRequest request) const
virtual

Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.

See Also:

AWS API Reference

◆ DeleteClusterAsync()

template<typename DeleteClusterRequestT = Model::DeleteClusterRequest>
void Aws::Kafka::KafkaClient::DeleteClusterAsync ( const DeleteClusterRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DeleteCluster that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 298 of file KafkaClient.h.

◆ DeleteClusterCallable()

template<typename DeleteClusterRequestT = Model::DeleteClusterRequest>
Model::DeleteClusterOutcomeCallable Aws::Kafka::KafkaClient::DeleteClusterCallable ( const DeleteClusterRequestT &  request) const
inline

A Callable wrapper for DeleteCluster that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 289 of file KafkaClient.h.

◆ DeleteClusterPolicy()

virtual Model::DeleteClusterPolicyOutcome Aws::Kafka::KafkaClient::DeleteClusterPolicy ( const Model::DeleteClusterPolicyRequest request) const
virtual

Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.

See Also:

AWS API Reference

◆ DeleteClusterPolicyAsync()

template<typename DeleteClusterPolicyRequestT = Model::DeleteClusterPolicyRequest>
void Aws::Kafka::KafkaClient::DeleteClusterPolicyAsync ( const DeleteClusterPolicyRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DeleteClusterPolicy that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 326 of file KafkaClient.h.

◆ DeleteClusterPolicyCallable()

template<typename DeleteClusterPolicyRequestT = Model::DeleteClusterPolicyRequest>
Model::DeleteClusterPolicyOutcomeCallable Aws::Kafka::KafkaClient::DeleteClusterPolicyCallable ( const DeleteClusterPolicyRequestT &  request) const
inline

A Callable wrapper for DeleteClusterPolicy that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 317 of file KafkaClient.h.

◆ DeleteConfiguration()

virtual Model::DeleteConfigurationOutcome Aws::Kafka::KafkaClient::DeleteConfiguration ( const Model::DeleteConfigurationRequest request) const
virtual

Deletes an MSK Configuration.

See Also:

AWS API Reference

◆ DeleteConfigurationAsync()

template<typename DeleteConfigurationRequestT = Model::DeleteConfigurationRequest>
void Aws::Kafka::KafkaClient::DeleteConfigurationAsync ( const DeleteConfigurationRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DeleteConfiguration that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 354 of file KafkaClient.h.

◆ DeleteConfigurationCallable()

template<typename DeleteConfigurationRequestT = Model::DeleteConfigurationRequest>
Model::DeleteConfigurationOutcomeCallable Aws::Kafka::KafkaClient::DeleteConfigurationCallable ( const DeleteConfigurationRequestT &  request) const
inline

A Callable wrapper for DeleteConfiguration that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 345 of file KafkaClient.h.

◆ DeleteReplicator()

virtual Model::DeleteReplicatorOutcome Aws::Kafka::KafkaClient::DeleteReplicator ( const Model::DeleteReplicatorRequest request) const
virtual

Deletes a replicator.

See Also:

AWS API Reference

◆ DeleteReplicatorAsync()

template<typename DeleteReplicatorRequestT = Model::DeleteReplicatorRequest>
void Aws::Kafka::KafkaClient::DeleteReplicatorAsync ( const DeleteReplicatorRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DeleteReplicator that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 379 of file KafkaClient.h.

◆ DeleteReplicatorCallable()

template<typename DeleteReplicatorRequestT = Model::DeleteReplicatorRequest>
Model::DeleteReplicatorOutcomeCallable Aws::Kafka::KafkaClient::DeleteReplicatorCallable ( const DeleteReplicatorRequestT &  request) const
inline

A Callable wrapper for DeleteReplicator that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 370 of file KafkaClient.h.

◆ DeleteVpcConnection()

virtual Model::DeleteVpcConnectionOutcome Aws::Kafka::KafkaClient::DeleteVpcConnection ( const Model::DeleteVpcConnectionRequest request) const
virtual

Deletes a MSK VPC connection.

See Also:

AWS API Reference

◆ DeleteVpcConnectionAsync()

template<typename DeleteVpcConnectionRequestT = Model::DeleteVpcConnectionRequest>
void Aws::Kafka::KafkaClient::DeleteVpcConnectionAsync ( const DeleteVpcConnectionRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DeleteVpcConnection that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 407 of file KafkaClient.h.

◆ DeleteVpcConnectionCallable()

template<typename DeleteVpcConnectionRequestT = Model::DeleteVpcConnectionRequest>
Model::DeleteVpcConnectionOutcomeCallable Aws::Kafka::KafkaClient::DeleteVpcConnectionCallable ( const DeleteVpcConnectionRequestT &  request) const
inline

A Callable wrapper for DeleteVpcConnection that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 398 of file KafkaClient.h.

◆ DescribeCluster()

virtual Model::DescribeClusterOutcome Aws::Kafka::KafkaClient::DescribeCluster ( const Model::DescribeClusterRequest request) const
virtual

Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.

See Also:

AWS API Reference

◆ DescribeClusterAsync()

template<typename DescribeClusterRequestT = Model::DescribeClusterRequest>
void Aws::Kafka::KafkaClient::DescribeClusterAsync ( const DescribeClusterRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeCluster that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 435 of file KafkaClient.h.

◆ DescribeClusterCallable()

template<typename DescribeClusterRequestT = Model::DescribeClusterRequest>
Model::DescribeClusterOutcomeCallable Aws::Kafka::KafkaClient::DescribeClusterCallable ( const DescribeClusterRequestT &  request) const
inline

A Callable wrapper for DescribeCluster that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 426 of file KafkaClient.h.

◆ DescribeClusterOperation()

virtual Model::DescribeClusterOperationOutcome Aws::Kafka::KafkaClient::DescribeClusterOperation ( const Model::DescribeClusterOperationRequest request) const
virtual

Returns a description of the cluster operation specified by the ARN.

See Also:

AWS API Reference

◆ DescribeClusterOperationAsync()

template<typename DescribeClusterOperationRequestT = Model::DescribeClusterOperationRequest>
void Aws::Kafka::KafkaClient::DescribeClusterOperationAsync ( const DescribeClusterOperationRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeClusterOperation that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 463 of file KafkaClient.h.

◆ DescribeClusterOperationCallable()

template<typename DescribeClusterOperationRequestT = Model::DescribeClusterOperationRequest>
Model::DescribeClusterOperationOutcomeCallable Aws::Kafka::KafkaClient::DescribeClusterOperationCallable ( const DescribeClusterOperationRequestT &  request) const
inline

A Callable wrapper for DescribeClusterOperation that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 454 of file KafkaClient.h.

◆ DescribeClusterOperationV2()

virtual Model::DescribeClusterOperationV2Outcome Aws::Kafka::KafkaClient::DescribeClusterOperationV2 ( const Model::DescribeClusterOperationV2Request request) const
virtual

Returns a description of the cluster operation specified by the ARN.

See Also:

AWS API Reference

◆ DescribeClusterOperationV2Async()

template<typename DescribeClusterOperationV2RequestT = Model::DescribeClusterOperationV2Request>
void Aws::Kafka::KafkaClient::DescribeClusterOperationV2Async ( const DescribeClusterOperationV2RequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeClusterOperationV2 that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 491 of file KafkaClient.h.

◆ DescribeClusterOperationV2Callable()

template<typename DescribeClusterOperationV2RequestT = Model::DescribeClusterOperationV2Request>
Model::DescribeClusterOperationV2OutcomeCallable Aws::Kafka::KafkaClient::DescribeClusterOperationV2Callable ( const DescribeClusterOperationV2RequestT &  request) const
inline

A Callable wrapper for DescribeClusterOperationV2 that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 482 of file KafkaClient.h.

◆ DescribeClusterV2()

virtual Model::DescribeClusterV2Outcome Aws::Kafka::KafkaClient::DescribeClusterV2 ( const Model::DescribeClusterV2Request request) const
virtual

Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.

See Also:

AWS API Reference

◆ DescribeClusterV2Async()

template<typename DescribeClusterV2RequestT = Model::DescribeClusterV2Request>
void Aws::Kafka::KafkaClient::DescribeClusterV2Async ( const DescribeClusterV2RequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeClusterV2 that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 519 of file KafkaClient.h.

◆ DescribeClusterV2Callable()

template<typename DescribeClusterV2RequestT = Model::DescribeClusterV2Request>
Model::DescribeClusterV2OutcomeCallable Aws::Kafka::KafkaClient::DescribeClusterV2Callable ( const DescribeClusterV2RequestT &  request) const
inline

A Callable wrapper for DescribeClusterV2 that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 510 of file KafkaClient.h.

◆ DescribeConfiguration()

virtual Model::DescribeConfigurationOutcome Aws::Kafka::KafkaClient::DescribeConfiguration ( const Model::DescribeConfigurationRequest request) const
virtual

Returns a description of this MSK configuration.

See Also:

AWS API Reference

◆ DescribeConfigurationAsync()

template<typename DescribeConfigurationRequestT = Model::DescribeConfigurationRequest>
void Aws::Kafka::KafkaClient::DescribeConfigurationAsync ( const DescribeConfigurationRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeConfiguration that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 547 of file KafkaClient.h.

◆ DescribeConfigurationCallable()

template<typename DescribeConfigurationRequestT = Model::DescribeConfigurationRequest>
Model::DescribeConfigurationOutcomeCallable Aws::Kafka::KafkaClient::DescribeConfigurationCallable ( const DescribeConfigurationRequestT &  request) const
inline

A Callable wrapper for DescribeConfiguration that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 538 of file KafkaClient.h.

◆ DescribeConfigurationRevision()

virtual Model::DescribeConfigurationRevisionOutcome Aws::Kafka::KafkaClient::DescribeConfigurationRevision ( const Model::DescribeConfigurationRevisionRequest request) const
virtual

Returns a description of this revision of the configuration.

See Also:

AWS API Reference

◆ DescribeConfigurationRevisionAsync()

template<typename DescribeConfigurationRevisionRequestT = Model::DescribeConfigurationRevisionRequest>
void Aws::Kafka::KafkaClient::DescribeConfigurationRevisionAsync ( const DescribeConfigurationRevisionRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeConfigurationRevision that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 575 of file KafkaClient.h.

◆ DescribeConfigurationRevisionCallable()

template<typename DescribeConfigurationRevisionRequestT = Model::DescribeConfigurationRevisionRequest>
Model::DescribeConfigurationRevisionOutcomeCallable Aws::Kafka::KafkaClient::DescribeConfigurationRevisionCallable ( const DescribeConfigurationRevisionRequestT &  request) const
inline

A Callable wrapper for DescribeConfigurationRevision that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 566 of file KafkaClient.h.

◆ DescribeReplicator()

virtual Model::DescribeReplicatorOutcome Aws::Kafka::KafkaClient::DescribeReplicator ( const Model::DescribeReplicatorRequest request) const
virtual

Describes a replicator.

See Also:

AWS API Reference

◆ DescribeReplicatorAsync()

template<typename DescribeReplicatorRequestT = Model::DescribeReplicatorRequest>
void Aws::Kafka::KafkaClient::DescribeReplicatorAsync ( const DescribeReplicatorRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeReplicator that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 600 of file KafkaClient.h.

◆ DescribeReplicatorCallable()

template<typename DescribeReplicatorRequestT = Model::DescribeReplicatorRequest>
Model::DescribeReplicatorOutcomeCallable Aws::Kafka::KafkaClient::DescribeReplicatorCallable ( const DescribeReplicatorRequestT &  request) const
inline

A Callable wrapper for DescribeReplicator that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 591 of file KafkaClient.h.

◆ DescribeVpcConnection()

virtual Model::DescribeVpcConnectionOutcome Aws::Kafka::KafkaClient::DescribeVpcConnection ( const Model::DescribeVpcConnectionRequest request) const
virtual

Returns a description of this MSK VPC connection.

See Also:

AWS API Reference

◆ DescribeVpcConnectionAsync()

template<typename DescribeVpcConnectionRequestT = Model::DescribeVpcConnectionRequest>
void Aws::Kafka::KafkaClient::DescribeVpcConnectionAsync ( const DescribeVpcConnectionRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for DescribeVpcConnection that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 628 of file KafkaClient.h.

◆ DescribeVpcConnectionCallable()

template<typename DescribeVpcConnectionRequestT = Model::DescribeVpcConnectionRequest>
Model::DescribeVpcConnectionOutcomeCallable Aws::Kafka::KafkaClient::DescribeVpcConnectionCallable ( const DescribeVpcConnectionRequestT &  request) const
inline

A Callable wrapper for DescribeVpcConnection that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 619 of file KafkaClient.h.

◆ GetAllocationTag()

static const char * Aws::Kafka::KafkaClient::GetAllocationTag ( )
static

◆ GetBootstrapBrokers()

virtual Model::GetBootstrapBrokersOutcome Aws::Kafka::KafkaClient::GetBootstrapBrokers ( const Model::GetBootstrapBrokersRequest request) const
virtual

A list of brokers that a client application can use to bootstrap. This list doesn't necessarily include all of the brokers in the cluster. The following Python 3.6 example shows how you can use the Amazon Resource Name (ARN) of a cluster to get its bootstrap brokers. If you don't know the ARN of your cluster, you can use the ListClusters operation to get the ARNs of all the clusters in this account and Region.

See Also:

AWS API Reference

◆ GetBootstrapBrokersAsync()

template<typename GetBootstrapBrokersRequestT = Model::GetBootstrapBrokersRequest>
void Aws::Kafka::KafkaClient::GetBootstrapBrokersAsync ( const GetBootstrapBrokersRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for GetBootstrapBrokers that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 661 of file KafkaClient.h.

◆ GetBootstrapBrokersCallable()

template<typename GetBootstrapBrokersRequestT = Model::GetBootstrapBrokersRequest>
Model::GetBootstrapBrokersOutcomeCallable Aws::Kafka::KafkaClient::GetBootstrapBrokersCallable ( const GetBootstrapBrokersRequestT &  request) const
inline

A Callable wrapper for GetBootstrapBrokers that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 652 of file KafkaClient.h.

◆ GetClusterPolicy()

virtual Model::GetClusterPolicyOutcome Aws::Kafka::KafkaClient::GetClusterPolicy ( const Model::GetClusterPolicyRequest request) const
virtual

Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.

See Also:

AWS API Reference

◆ GetClusterPolicyAsync()

template<typename GetClusterPolicyRequestT = Model::GetClusterPolicyRequest>
void Aws::Kafka::KafkaClient::GetClusterPolicyAsync ( const GetClusterPolicyRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for GetClusterPolicy that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 689 of file KafkaClient.h.

◆ GetClusterPolicyCallable()

template<typename GetClusterPolicyRequestT = Model::GetClusterPolicyRequest>
Model::GetClusterPolicyOutcomeCallable Aws::Kafka::KafkaClient::GetClusterPolicyCallable ( const GetClusterPolicyRequestT &  request) const
inline

A Callable wrapper for GetClusterPolicy that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 680 of file KafkaClient.h.

◆ GetCompatibleKafkaVersions()

virtual Model::GetCompatibleKafkaVersionsOutcome Aws::Kafka::KafkaClient::GetCompatibleKafkaVersions ( const Model::GetCompatibleKafkaVersionsRequest request = {}) const
virtual

Gets the Apache Kafka versions to which you can update the MSK cluster.

See Also:

AWS API Reference

◆ GetCompatibleKafkaVersionsAsync()

template<typename GetCompatibleKafkaVersionsRequestT = Model::GetCompatibleKafkaVersionsRequest>
void Aws::Kafka::KafkaClient::GetCompatibleKafkaVersionsAsync ( const GetCompatibleKafkaVersionsResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const GetCompatibleKafkaVersionsRequestT &  request = {} 
) const
inline

An Async wrapper for GetCompatibleKafkaVersions that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 717 of file KafkaClient.h.

◆ GetCompatibleKafkaVersionsCallable()

template<typename GetCompatibleKafkaVersionsRequestT = Model::GetCompatibleKafkaVersionsRequest>
Model::GetCompatibleKafkaVersionsOutcomeCallable Aws::Kafka::KafkaClient::GetCompatibleKafkaVersionsCallable ( const GetCompatibleKafkaVersionsRequestT &  request = {}) const
inline

A Callable wrapper for GetCompatibleKafkaVersions that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 708 of file KafkaClient.h.

◆ GetServiceName()

static const char * Aws::Kafka::KafkaClient::GetServiceName ( )
static

◆ ListClientVpcConnections()

virtual Model::ListClientVpcConnectionsOutcome Aws::Kafka::KafkaClient::ListClientVpcConnections ( const Model::ListClientVpcConnectionsRequest request) const
virtual

Returns a list of all the VPC connections in this Region.

See Also:

AWS API Reference

◆ ListClientVpcConnectionsAsync()

template<typename ListClientVpcConnectionsRequestT = Model::ListClientVpcConnectionsRequest>
void Aws::Kafka::KafkaClient::ListClientVpcConnectionsAsync ( const ListClientVpcConnectionsRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListClientVpcConnections that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 745 of file KafkaClient.h.

◆ ListClientVpcConnectionsCallable()

template<typename ListClientVpcConnectionsRequestT = Model::ListClientVpcConnectionsRequest>
Model::ListClientVpcConnectionsOutcomeCallable Aws::Kafka::KafkaClient::ListClientVpcConnectionsCallable ( const ListClientVpcConnectionsRequestT &  request) const
inline

A Callable wrapper for ListClientVpcConnections that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 736 of file KafkaClient.h.

◆ ListClusterOperations()

virtual Model::ListClusterOperationsOutcome Aws::Kafka::KafkaClient::ListClusterOperations ( const Model::ListClusterOperationsRequest request) const
virtual

Returns a list of all the operations that have been performed on the specified MSK cluster.

See Also:

AWS API Reference

◆ ListClusterOperationsAsync()

template<typename ListClusterOperationsRequestT = Model::ListClusterOperationsRequest>
void Aws::Kafka::KafkaClient::ListClusterOperationsAsync ( const ListClusterOperationsRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListClusterOperations that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 773 of file KafkaClient.h.

◆ ListClusterOperationsCallable()

template<typename ListClusterOperationsRequestT = Model::ListClusterOperationsRequest>
Model::ListClusterOperationsOutcomeCallable Aws::Kafka::KafkaClient::ListClusterOperationsCallable ( const ListClusterOperationsRequestT &  request) const
inline

A Callable wrapper for ListClusterOperations that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 764 of file KafkaClient.h.

◆ ListClusterOperationsV2()

virtual Model::ListClusterOperationsV2Outcome Aws::Kafka::KafkaClient::ListClusterOperationsV2 ( const Model::ListClusterOperationsV2Request request) const
virtual

Returns a list of all the operations that have been performed on the specified MSK cluster.

See Also:

AWS API Reference

◆ ListClusterOperationsV2Async()

template<typename ListClusterOperationsV2RequestT = Model::ListClusterOperationsV2Request>
void Aws::Kafka::KafkaClient::ListClusterOperationsV2Async ( const ListClusterOperationsV2RequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListClusterOperationsV2 that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 801 of file KafkaClient.h.

◆ ListClusterOperationsV2Callable()

template<typename ListClusterOperationsV2RequestT = Model::ListClusterOperationsV2Request>
Model::ListClusterOperationsV2OutcomeCallable Aws::Kafka::KafkaClient::ListClusterOperationsV2Callable ( const ListClusterOperationsV2RequestT &  request) const
inline

A Callable wrapper for ListClusterOperationsV2 that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 792 of file KafkaClient.h.

◆ ListClusters()

virtual Model::ListClustersOutcome Aws::Kafka::KafkaClient::ListClusters ( const Model::ListClustersRequest request = {}) const
virtual

Returns a list of all the MSK clusters in the current Region.

See Also:

AWS API Reference

◆ ListClustersAsync()

template<typename ListClustersRequestT = Model::ListClustersRequest>
void Aws::Kafka::KafkaClient::ListClustersAsync ( const ListClustersResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const ListClustersRequestT &  request = {} 
) const
inline

An Async wrapper for ListClusters that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 829 of file KafkaClient.h.

◆ ListClustersCallable()

template<typename ListClustersRequestT = Model::ListClustersRequest>
Model::ListClustersOutcomeCallable Aws::Kafka::KafkaClient::ListClustersCallable ( const ListClustersRequestT &  request = {}) const
inline

A Callable wrapper for ListClusters that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 820 of file KafkaClient.h.

◆ ListClustersV2()

virtual Model::ListClustersV2Outcome Aws::Kafka::KafkaClient::ListClustersV2 ( const Model::ListClustersV2Request request = {}) const
virtual

Returns a list of all the MSK clusters in the current Region.

See Also:

AWS API Reference

◆ ListClustersV2Async()

template<typename ListClustersV2RequestT = Model::ListClustersV2Request>
void Aws::Kafka::KafkaClient::ListClustersV2Async ( const ListClustersV2ResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const ListClustersV2RequestT &  request = {} 
) const
inline

An Async wrapper for ListClustersV2 that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 857 of file KafkaClient.h.

◆ ListClustersV2Callable()

template<typename ListClustersV2RequestT = Model::ListClustersV2Request>
Model::ListClustersV2OutcomeCallable Aws::Kafka::KafkaClient::ListClustersV2Callable ( const ListClustersV2RequestT &  request = {}) const
inline

A Callable wrapper for ListClustersV2 that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 848 of file KafkaClient.h.

◆ ListConfigurationRevisions()

virtual Model::ListConfigurationRevisionsOutcome Aws::Kafka::KafkaClient::ListConfigurationRevisions ( const Model::ListConfigurationRevisionsRequest request) const
virtual

Returns a list of all the MSK configurations in this Region.

See Also:

AWS API Reference

◆ ListConfigurationRevisionsAsync()

template<typename ListConfigurationRevisionsRequestT = Model::ListConfigurationRevisionsRequest>
void Aws::Kafka::KafkaClient::ListConfigurationRevisionsAsync ( const ListConfigurationRevisionsRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListConfigurationRevisions that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 885 of file KafkaClient.h.

◆ ListConfigurationRevisionsCallable()

template<typename ListConfigurationRevisionsRequestT = Model::ListConfigurationRevisionsRequest>
Model::ListConfigurationRevisionsOutcomeCallable Aws::Kafka::KafkaClient::ListConfigurationRevisionsCallable ( const ListConfigurationRevisionsRequestT &  request) const
inline

A Callable wrapper for ListConfigurationRevisions that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 876 of file KafkaClient.h.

◆ ListConfigurations()

virtual Model::ListConfigurationsOutcome Aws::Kafka::KafkaClient::ListConfigurations ( const Model::ListConfigurationsRequest request = {}) const
virtual

Returns a list of all the MSK configurations in this Region.

See Also:

AWS API Reference

◆ ListConfigurationsAsync()

template<typename ListConfigurationsRequestT = Model::ListConfigurationsRequest>
void Aws::Kafka::KafkaClient::ListConfigurationsAsync ( const ListConfigurationsResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const ListConfigurationsRequestT &  request = {} 
) const
inline

An Async wrapper for ListConfigurations that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 913 of file KafkaClient.h.

◆ ListConfigurationsCallable()

template<typename ListConfigurationsRequestT = Model::ListConfigurationsRequest>
Model::ListConfigurationsOutcomeCallable Aws::Kafka::KafkaClient::ListConfigurationsCallable ( const ListConfigurationsRequestT &  request = {}) const
inline

A Callable wrapper for ListConfigurations that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 904 of file KafkaClient.h.

◆ ListKafkaVersions()

virtual Model::ListKafkaVersionsOutcome Aws::Kafka::KafkaClient::ListKafkaVersions ( const Model::ListKafkaVersionsRequest request = {}) const
virtual

Returns a list of Apache Kafka versions.

See Also:

AWS API Reference

◆ ListKafkaVersionsAsync()

template<typename ListKafkaVersionsRequestT = Model::ListKafkaVersionsRequest>
void Aws::Kafka::KafkaClient::ListKafkaVersionsAsync ( const ListKafkaVersionsResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const ListKafkaVersionsRequestT &  request = {} 
) const
inline

An Async wrapper for ListKafkaVersions that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 941 of file KafkaClient.h.

◆ ListKafkaVersionsCallable()

template<typename ListKafkaVersionsRequestT = Model::ListKafkaVersionsRequest>
Model::ListKafkaVersionsOutcomeCallable Aws::Kafka::KafkaClient::ListKafkaVersionsCallable ( const ListKafkaVersionsRequestT &  request = {}) const
inline

A Callable wrapper for ListKafkaVersions that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 932 of file KafkaClient.h.

◆ ListNodes()

virtual Model::ListNodesOutcome Aws::Kafka::KafkaClient::ListNodes ( const Model::ListNodesRequest request) const
virtual

Returns a list of the broker nodes in the cluster.

See Also:

AWS API Reference

◆ ListNodesAsync()

template<typename ListNodesRequestT = Model::ListNodesRequest>
void Aws::Kafka::KafkaClient::ListNodesAsync ( const ListNodesRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListNodes that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 969 of file KafkaClient.h.

◆ ListNodesCallable()

template<typename ListNodesRequestT = Model::ListNodesRequest>
Model::ListNodesOutcomeCallable Aws::Kafka::KafkaClient::ListNodesCallable ( const ListNodesRequestT &  request) const
inline

A Callable wrapper for ListNodes that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 960 of file KafkaClient.h.

◆ ListReplicators()

virtual Model::ListReplicatorsOutcome Aws::Kafka::KafkaClient::ListReplicators ( const Model::ListReplicatorsRequest request = {}) const
virtual

Lists the replicators.

See Also:

AWS API Reference

◆ ListReplicatorsAsync()

template<typename ListReplicatorsRequestT = Model::ListReplicatorsRequest>
void Aws::Kafka::KafkaClient::ListReplicatorsAsync ( const ListReplicatorsResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const ListReplicatorsRequestT &  request = {} 
) const
inline

An Async wrapper for ListReplicators that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 994 of file KafkaClient.h.

◆ ListReplicatorsCallable()

template<typename ListReplicatorsRequestT = Model::ListReplicatorsRequest>
Model::ListReplicatorsOutcomeCallable Aws::Kafka::KafkaClient::ListReplicatorsCallable ( const ListReplicatorsRequestT &  request = {}) const
inline

A Callable wrapper for ListReplicators that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 985 of file KafkaClient.h.

◆ ListScramSecrets()

virtual Model::ListScramSecretsOutcome Aws::Kafka::KafkaClient::ListScramSecrets ( const Model::ListScramSecretsRequest request) const
virtual

Returns a list of the Scram Secrets associated with an Amazon MSK cluster.

See Also:

AWS API Reference

◆ ListScramSecretsAsync()

template<typename ListScramSecretsRequestT = Model::ListScramSecretsRequest>
void Aws::Kafka::KafkaClient::ListScramSecretsAsync ( const ListScramSecretsRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListScramSecrets that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1022 of file KafkaClient.h.

◆ ListScramSecretsCallable()

template<typename ListScramSecretsRequestT = Model::ListScramSecretsRequest>
Model::ListScramSecretsOutcomeCallable Aws::Kafka::KafkaClient::ListScramSecretsCallable ( const ListScramSecretsRequestT &  request) const
inline

A Callable wrapper for ListScramSecrets that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1013 of file KafkaClient.h.

◆ ListTagsForResource()

virtual Model::ListTagsForResourceOutcome Aws::Kafka::KafkaClient::ListTagsForResource ( const Model::ListTagsForResourceRequest request) const
virtual

Returns a list of the tags associated with the specified resource.

See Also:

AWS API Reference

◆ ListTagsForResourceAsync()

template<typename ListTagsForResourceRequestT = Model::ListTagsForResourceRequest>
void Aws::Kafka::KafkaClient::ListTagsForResourceAsync ( const ListTagsForResourceRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for ListTagsForResource that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1050 of file KafkaClient.h.

◆ ListTagsForResourceCallable()

template<typename ListTagsForResourceRequestT = Model::ListTagsForResourceRequest>
Model::ListTagsForResourceOutcomeCallable Aws::Kafka::KafkaClient::ListTagsForResourceCallable ( const ListTagsForResourceRequestT &  request) const
inline

A Callable wrapper for ListTagsForResource that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1041 of file KafkaClient.h.

◆ ListVpcConnections()

virtual Model::ListVpcConnectionsOutcome Aws::Kafka::KafkaClient::ListVpcConnections ( const Model::ListVpcConnectionsRequest request = {}) const
virtual

Returns a list of all the VPC connections in this Region.

See Also:

AWS API Reference

◆ ListVpcConnectionsAsync()

template<typename ListVpcConnectionsRequestT = Model::ListVpcConnectionsRequest>
void Aws::Kafka::KafkaClient::ListVpcConnectionsAsync ( const ListVpcConnectionsResponseReceivedHandler handler,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr,
const ListVpcConnectionsRequestT &  request = {} 
) const
inline

An Async wrapper for ListVpcConnections that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1078 of file KafkaClient.h.

◆ ListVpcConnectionsCallable()

template<typename ListVpcConnectionsRequestT = Model::ListVpcConnectionsRequest>
Model::ListVpcConnectionsOutcomeCallable Aws::Kafka::KafkaClient::ListVpcConnectionsCallable ( const ListVpcConnectionsRequestT &  request = {}) const
inline

A Callable wrapper for ListVpcConnections that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1069 of file KafkaClient.h.

◆ OverrideEndpoint()

void Aws::Kafka::KafkaClient::OverrideEndpoint ( const Aws::String endpoint)

◆ PutClusterPolicy()

virtual Model::PutClusterPolicyOutcome Aws::Kafka::KafkaClient::PutClusterPolicy ( const Model::PutClusterPolicyRequest request) const
virtual

Creates or updates the MSK cluster policy specified by the cluster Amazon Resource Name (ARN) in the request.

See Also:

AWS API Reference

◆ PutClusterPolicyAsync()

template<typename PutClusterPolicyRequestT = Model::PutClusterPolicyRequest>
void Aws::Kafka::KafkaClient::PutClusterPolicyAsync ( const PutClusterPolicyRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for PutClusterPolicy that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1107 of file KafkaClient.h.

◆ PutClusterPolicyCallable()

template<typename PutClusterPolicyRequestT = Model::PutClusterPolicyRequest>
Model::PutClusterPolicyOutcomeCallable Aws::Kafka::KafkaClient::PutClusterPolicyCallable ( const PutClusterPolicyRequestT &  request) const
inline

A Callable wrapper for PutClusterPolicy that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1098 of file KafkaClient.h.

◆ RebootBroker()

virtual Model::RebootBrokerOutcome Aws::Kafka::KafkaClient::RebootBroker ( const Model::RebootBrokerRequest request) const
virtual

Reboots brokers.

See Also:

AWS API Reference

◆ RebootBrokerAsync()

template<typename RebootBrokerRequestT = Model::RebootBrokerRequest>
void Aws::Kafka::KafkaClient::RebootBrokerAsync ( const RebootBrokerRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for RebootBroker that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1132 of file KafkaClient.h.

◆ RebootBrokerCallable()

template<typename RebootBrokerRequestT = Model::RebootBrokerRequest>
Model::RebootBrokerOutcomeCallable Aws::Kafka::KafkaClient::RebootBrokerCallable ( const RebootBrokerRequestT &  request) const
inline

A Callable wrapper for RebootBroker that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1123 of file KafkaClient.h.

◆ RejectClientVpcConnection()

virtual Model::RejectClientVpcConnectionOutcome Aws::Kafka::KafkaClient::RejectClientVpcConnection ( const Model::RejectClientVpcConnectionRequest request) const
virtual

Returns empty response.

See Also:

AWS API Reference

◆ RejectClientVpcConnectionAsync()

template<typename RejectClientVpcConnectionRequestT = Model::RejectClientVpcConnectionRequest>
void Aws::Kafka::KafkaClient::RejectClientVpcConnectionAsync ( const RejectClientVpcConnectionRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for RejectClientVpcConnection that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1159 of file KafkaClient.h.

◆ RejectClientVpcConnectionCallable()

template<typename RejectClientVpcConnectionRequestT = Model::RejectClientVpcConnectionRequest>
Model::RejectClientVpcConnectionOutcomeCallable Aws::Kafka::KafkaClient::RejectClientVpcConnectionCallable ( const RejectClientVpcConnectionRequestT &  request) const
inline

A Callable wrapper for RejectClientVpcConnection that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1150 of file KafkaClient.h.

◆ TagResource()

virtual Model::TagResourceOutcome Aws::Kafka::KafkaClient::TagResource ( const Model::TagResourceRequest request) const
virtual

Adds tags to the specified MSK resource.

See Also:

AWS API Reference

◆ TagResourceAsync()

template<typename TagResourceRequestT = Model::TagResourceRequest>
void Aws::Kafka::KafkaClient::TagResourceAsync ( const TagResourceRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for TagResource that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1187 of file KafkaClient.h.

◆ TagResourceCallable()

template<typename TagResourceRequestT = Model::TagResourceRequest>
Model::TagResourceOutcomeCallable Aws::Kafka::KafkaClient::TagResourceCallable ( const TagResourceRequestT &  request) const
inline

A Callable wrapper for TagResource that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1178 of file KafkaClient.h.

◆ UntagResource()

virtual Model::UntagResourceOutcome Aws::Kafka::KafkaClient::UntagResource ( const Model::UntagResourceRequest request) const
virtual

Removes the tags associated with the keys that are provided in the query.

See Also:

AWS API Reference

◆ UntagResourceAsync()

template<typename UntagResourceRequestT = Model::UntagResourceRequest>
void Aws::Kafka::KafkaClient::UntagResourceAsync ( const UntagResourceRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UntagResource that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1215 of file KafkaClient.h.

◆ UntagResourceCallable()

template<typename UntagResourceRequestT = Model::UntagResourceRequest>
Model::UntagResourceOutcomeCallable Aws::Kafka::KafkaClient::UntagResourceCallable ( const UntagResourceRequestT &  request) const
inline

A Callable wrapper for UntagResource that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1206 of file KafkaClient.h.

◆ UpdateBrokerCount()

virtual Model::UpdateBrokerCountOutcome Aws::Kafka::KafkaClient::UpdateBrokerCount ( const Model::UpdateBrokerCountRequest request) const
virtual

Updates the number of broker nodes in the cluster.

See Also:

AWS API Reference

◆ UpdateBrokerCountAsync()

template<typename UpdateBrokerCountRequestT = Model::UpdateBrokerCountRequest>
void Aws::Kafka::KafkaClient::UpdateBrokerCountAsync ( const UpdateBrokerCountRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateBrokerCount that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1243 of file KafkaClient.h.

◆ UpdateBrokerCountCallable()

template<typename UpdateBrokerCountRequestT = Model::UpdateBrokerCountRequest>
Model::UpdateBrokerCountOutcomeCallable Aws::Kafka::KafkaClient::UpdateBrokerCountCallable ( const UpdateBrokerCountRequestT &  request) const
inline

A Callable wrapper for UpdateBrokerCount that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1234 of file KafkaClient.h.

◆ UpdateBrokerStorage()

virtual Model::UpdateBrokerStorageOutcome Aws::Kafka::KafkaClient::UpdateBrokerStorage ( const Model::UpdateBrokerStorageRequest request) const
virtual

Updates the EBS storage associated with MSK brokers.

See Also:

AWS API Reference

◆ UpdateBrokerStorageAsync()

template<typename UpdateBrokerStorageRequestT = Model::UpdateBrokerStorageRequest>
void Aws::Kafka::KafkaClient::UpdateBrokerStorageAsync ( const UpdateBrokerStorageRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateBrokerStorage that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1271 of file KafkaClient.h.

◆ UpdateBrokerStorageCallable()

template<typename UpdateBrokerStorageRequestT = Model::UpdateBrokerStorageRequest>
Model::UpdateBrokerStorageOutcomeCallable Aws::Kafka::KafkaClient::UpdateBrokerStorageCallable ( const UpdateBrokerStorageRequestT &  request) const
inline

A Callable wrapper for UpdateBrokerStorage that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1262 of file KafkaClient.h.

◆ UpdateBrokerType()

virtual Model::UpdateBrokerTypeOutcome Aws::Kafka::KafkaClient::UpdateBrokerType ( const Model::UpdateBrokerTypeRequest request) const
virtual

Updates EC2 instance type.

See Also:


AWS API Reference

◆ UpdateBrokerTypeAsync()

template<typename UpdateBrokerTypeRequestT = Model::UpdateBrokerTypeRequest>
void Aws::Kafka::KafkaClient::UpdateBrokerTypeAsync ( const UpdateBrokerTypeRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateBrokerType that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1299 of file KafkaClient.h.

◆ UpdateBrokerTypeCallable()

template<typename UpdateBrokerTypeRequestT = Model::UpdateBrokerTypeRequest>
Model::UpdateBrokerTypeOutcomeCallable Aws::Kafka::KafkaClient::UpdateBrokerTypeCallable ( const UpdateBrokerTypeRequestT &  request) const
inline

A Callable wrapper for UpdateBrokerType that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1290 of file KafkaClient.h.

◆ UpdateClusterConfiguration()

virtual Model::UpdateClusterConfigurationOutcome Aws::Kafka::KafkaClient::UpdateClusterConfiguration ( const Model::UpdateClusterConfigurationRequest request) const
virtual

Updates the cluster with the configuration that is specified in the request body.

See Also:

AWS API Reference

◆ UpdateClusterConfigurationAsync()

template<typename UpdateClusterConfigurationRequestT = Model::UpdateClusterConfigurationRequest>
void Aws::Kafka::KafkaClient::UpdateClusterConfigurationAsync ( const UpdateClusterConfigurationRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateClusterConfiguration that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1327 of file KafkaClient.h.

◆ UpdateClusterConfigurationCallable()

template<typename UpdateClusterConfigurationRequestT = Model::UpdateClusterConfigurationRequest>
Model::UpdateClusterConfigurationOutcomeCallable Aws::Kafka::KafkaClient::UpdateClusterConfigurationCallable ( const UpdateClusterConfigurationRequestT &  request) const
inline

A Callable wrapper for UpdateClusterConfiguration that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1318 of file KafkaClient.h.

◆ UpdateClusterKafkaVersion()

virtual Model::UpdateClusterKafkaVersionOutcome Aws::Kafka::KafkaClient::UpdateClusterKafkaVersion ( const Model::UpdateClusterKafkaVersionRequest request) const
virtual

Updates the Apache Kafka version for the cluster.

See Also:

AWS API Reference

◆ UpdateClusterKafkaVersionAsync()

template<typename UpdateClusterKafkaVersionRequestT = Model::UpdateClusterKafkaVersionRequest>
void Aws::Kafka::KafkaClient::UpdateClusterKafkaVersionAsync ( const UpdateClusterKafkaVersionRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateClusterKafkaVersion that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1355 of file KafkaClient.h.

◆ UpdateClusterKafkaVersionCallable()

template<typename UpdateClusterKafkaVersionRequestT = Model::UpdateClusterKafkaVersionRequest>
Model::UpdateClusterKafkaVersionOutcomeCallable Aws::Kafka::KafkaClient::UpdateClusterKafkaVersionCallable ( const UpdateClusterKafkaVersionRequestT &  request) const
inline

A Callable wrapper for UpdateClusterKafkaVersion that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1346 of file KafkaClient.h.

◆ UpdateConfiguration()

virtual Model::UpdateConfigurationOutcome Aws::Kafka::KafkaClient::UpdateConfiguration ( const Model::UpdateConfigurationRequest request) const
virtual

Updates an MSK configuration.

See Also:

AWS API Reference

◆ UpdateConfigurationAsync()

template<typename UpdateConfigurationRequestT = Model::UpdateConfigurationRequest>
void Aws::Kafka::KafkaClient::UpdateConfigurationAsync ( const UpdateConfigurationRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateConfiguration that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1383 of file KafkaClient.h.

◆ UpdateConfigurationCallable()

template<typename UpdateConfigurationRequestT = Model::UpdateConfigurationRequest>
Model::UpdateConfigurationOutcomeCallable Aws::Kafka::KafkaClient::UpdateConfigurationCallable ( const UpdateConfigurationRequestT &  request) const
inline

A Callable wrapper for UpdateConfiguration that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1374 of file KafkaClient.h.

◆ UpdateConnectivity()

virtual Model::UpdateConnectivityOutcome Aws::Kafka::KafkaClient::UpdateConnectivity ( const Model::UpdateConnectivityRequest request) const
virtual

Updates the cluster's connectivity configuration.

See Also:

AWS API Reference

◆ UpdateConnectivityAsync()

template<typename UpdateConnectivityRequestT = Model::UpdateConnectivityRequest>
void Aws::Kafka::KafkaClient::UpdateConnectivityAsync ( const UpdateConnectivityRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateConnectivity that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1411 of file KafkaClient.h.

◆ UpdateConnectivityCallable()

template<typename UpdateConnectivityRequestT = Model::UpdateConnectivityRequest>
Model::UpdateConnectivityOutcomeCallable Aws::Kafka::KafkaClient::UpdateConnectivityCallable ( const UpdateConnectivityRequestT &  request) const
inline

A Callable wrapper for UpdateConnectivity that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1402 of file KafkaClient.h.

◆ UpdateMonitoring()

virtual Model::UpdateMonitoringOutcome Aws::Kafka::KafkaClient::UpdateMonitoring ( const Model::UpdateMonitoringRequest request) const
virtual

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.

See Also:

AWS API Reference

◆ UpdateMonitoringAsync()

template<typename UpdateMonitoringRequestT = Model::UpdateMonitoringRequest>
void Aws::Kafka::KafkaClient::UpdateMonitoringAsync ( const UpdateMonitoringRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateMonitoring that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1441 of file KafkaClient.h.

◆ UpdateMonitoringCallable()

template<typename UpdateMonitoringRequestT = Model::UpdateMonitoringRequest>
Model::UpdateMonitoringOutcomeCallable Aws::Kafka::KafkaClient::UpdateMonitoringCallable ( const UpdateMonitoringRequestT &  request) const
inline

A Callable wrapper for UpdateMonitoring that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1432 of file KafkaClient.h.

◆ UpdateReplicationInfo()

virtual Model::UpdateReplicationInfoOutcome Aws::Kafka::KafkaClient::UpdateReplicationInfo ( const Model::UpdateReplicationInfoRequest request) const
virtual

Updates replication info of a replicator.

See Also:

AWS API Reference

◆ UpdateReplicationInfoAsync()

template<typename UpdateReplicationInfoRequestT = Model::UpdateReplicationInfoRequest>
void Aws::Kafka::KafkaClient::UpdateReplicationInfoAsync ( const UpdateReplicationInfoRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateReplicationInfo that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1466 of file KafkaClient.h.

◆ UpdateReplicationInfoCallable()

template<typename UpdateReplicationInfoRequestT = Model::UpdateReplicationInfoRequest>
Model::UpdateReplicationInfoOutcomeCallable Aws::Kafka::KafkaClient::UpdateReplicationInfoCallable ( const UpdateReplicationInfoRequestT &  request) const
inline

A Callable wrapper for UpdateReplicationInfo that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1457 of file KafkaClient.h.

◆ UpdateSecurity()

virtual Model::UpdateSecurityOutcome Aws::Kafka::KafkaClient::UpdateSecurity ( const Model::UpdateSecurityRequest request) const
virtual

Updates the security settings for the cluster. You can use this operation to specify encryption and authentication on existing clusters.

See Also:

AWS API Reference

◆ UpdateSecurityAsync()

template<typename UpdateSecurityRequestT = Model::UpdateSecurityRequest>
void Aws::Kafka::KafkaClient::UpdateSecurityAsync ( const UpdateSecurityRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateSecurity that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1495 of file KafkaClient.h.

◆ UpdateSecurityCallable()

template<typename UpdateSecurityRequestT = Model::UpdateSecurityRequest>
Model::UpdateSecurityOutcomeCallable Aws::Kafka::KafkaClient::UpdateSecurityCallable ( const UpdateSecurityRequestT &  request) const
inline

A Callable wrapper for UpdateSecurity that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1486 of file KafkaClient.h.

◆ UpdateStorage()

virtual Model::UpdateStorageOutcome Aws::Kafka::KafkaClient::UpdateStorage ( const Model::UpdateStorageRequest request) const
virtual

Updates cluster broker volume size (or) sets cluster storage mode to TIERED.

See Also:

AWS API Reference

◆ UpdateStorageAsync()

template<typename UpdateStorageRequestT = Model::UpdateStorageRequest>
void Aws::Kafka::KafkaClient::UpdateStorageAsync ( const UpdateStorageRequestT &  request,
const std::shared_ptr< const Aws::Client::AsyncCallerContext > &  context = nullptr 
) const
inline

An Async wrapper for UpdateStorage that queues the request into a thread executor and triggers associated callback when operation has finished.

Definition at line 1521 of file KafkaClient.h.

◆ UpdateStorageCallable()

template<typename UpdateStorageRequestT = Model::UpdateStorageRequest>
Model::UpdateStorageOutcomeCallable Aws::Kafka::KafkaClient::UpdateStorageCallable ( const UpdateStorageRequestT &  request) const
inline

A Callable wrapper for UpdateStorage that returns a future to the operation so that it can be executed in parallel to other requests.

Definition at line 1512 of file KafkaClient.h.

Friends And Related Symbol Documentation

◆ Aws::Client::ClientWithAsyncTemplateMethods< KafkaClient >

Definition at line 1528 of file KafkaClient.h.


The documentation for this class was generated from the following file: