{-# OPTIONS_GHC -fno-warn-duplicate-exports #-} {-# OPTIONS_GHC -fno-warn-unused-imports #-} -- | -- Module : Amazonka.Kafka -- Copyright : (c) 2013-2023 Brendan Hay -- License : Mozilla Public License, v. 2.0. -- Maintainer : Brendan Hay -- Stability : auto-generated -- Portability : non-portable (GHC extensions) -- -- Derived from API version @2018-11-14@ of the AWS service descriptions, licensed under Apache 2.0. -- -- The operations for managing an Amazon MSK cluster. module Amazonka.Kafka ( -- * Service Configuration defaultService, -- * Errors -- $errors -- ** BadRequestException _BadRequestException, -- ** ConflictException _ConflictException, -- ** ForbiddenException _ForbiddenException, -- ** InternalServerErrorException _InternalServerErrorException, -- ** NotFoundException _NotFoundException, -- ** ServiceUnavailableException _ServiceUnavailableException, -- ** TooManyRequestsException _TooManyRequestsException, -- ** UnauthorizedException _UnauthorizedException, -- * Waiters -- $waiters -- * Operations -- $operations -- ** BatchAssociateScramSecret BatchAssociateScramSecret (BatchAssociateScramSecret'), newBatchAssociateScramSecret, BatchAssociateScramSecretResponse (BatchAssociateScramSecretResponse'), newBatchAssociateScramSecretResponse, -- ** BatchDisassociateScramSecret BatchDisassociateScramSecret (BatchDisassociateScramSecret'), newBatchDisassociateScramSecret, BatchDisassociateScramSecretResponse (BatchDisassociateScramSecretResponse'), newBatchDisassociateScramSecretResponse, -- ** CreateCluster CreateCluster (CreateCluster'), newCreateCluster, CreateClusterResponse (CreateClusterResponse'), newCreateClusterResponse, -- ** CreateClusterV2 CreateClusterV2 (CreateClusterV2'), newCreateClusterV2, CreateClusterV2Response (CreateClusterV2Response'), newCreateClusterV2Response, -- ** CreateConfiguration CreateConfiguration (CreateConfiguration'), newCreateConfiguration, CreateConfigurationResponse (CreateConfigurationResponse'), newCreateConfigurationResponse, -- ** DeleteCluster DeleteCluster (DeleteCluster'), newDeleteCluster, DeleteClusterResponse (DeleteClusterResponse'), newDeleteClusterResponse, -- ** DeleteConfiguration DeleteConfiguration (DeleteConfiguration'), newDeleteConfiguration, DeleteConfigurationResponse (DeleteConfigurationResponse'), newDeleteConfigurationResponse, -- ** DescribeCluster DescribeCluster (DescribeCluster'), newDescribeCluster, DescribeClusterResponse (DescribeClusterResponse'), newDescribeClusterResponse, -- ** DescribeClusterOperation DescribeClusterOperation (DescribeClusterOperation'), newDescribeClusterOperation, DescribeClusterOperationResponse (DescribeClusterOperationResponse'), newDescribeClusterOperationResponse, -- ** DescribeClusterV2 DescribeClusterV2 (DescribeClusterV2'), newDescribeClusterV2, DescribeClusterV2Response (DescribeClusterV2Response'), newDescribeClusterV2Response, -- ** DescribeConfiguration DescribeConfiguration (DescribeConfiguration'), newDescribeConfiguration, DescribeConfigurationResponse (DescribeConfigurationResponse'), newDescribeConfigurationResponse, -- ** DescribeConfigurationRevision DescribeConfigurationRevision (DescribeConfigurationRevision'), newDescribeConfigurationRevision, DescribeConfigurationRevisionResponse (DescribeConfigurationRevisionResponse'), newDescribeConfigurationRevisionResponse, -- ** GetBootstrapBrokers GetBootstrapBrokers (GetBootstrapBrokers'), newGetBootstrapBrokers, GetBootstrapBrokersResponse (GetBootstrapBrokersResponse'), newGetBootstrapBrokersResponse, -- ** GetCompatibleKafkaVersions GetCompatibleKafkaVersions (GetCompatibleKafkaVersions'), newGetCompatibleKafkaVersions, GetCompatibleKafkaVersionsResponse (GetCompatibleKafkaVersionsResponse'), newGetCompatibleKafkaVersionsResponse, -- ** ListClusterOperations (Paginated) ListClusterOperations (ListClusterOperations'), newListClusterOperations, ListClusterOperationsResponse (ListClusterOperationsResponse'), newListClusterOperationsResponse, -- ** ListClusters (Paginated) ListClusters (ListClusters'), newListClusters, ListClustersResponse (ListClustersResponse'), newListClustersResponse, -- ** ListClustersV2 (Paginated) ListClustersV2 (ListClustersV2'), newListClustersV2, ListClustersV2Response (ListClustersV2Response'), newListClustersV2Response, -- ** ListConfigurationRevisions (Paginated) ListConfigurationRevisions (ListConfigurationRevisions'), newListConfigurationRevisions, ListConfigurationRevisionsResponse (ListConfigurationRevisionsResponse'), newListConfigurationRevisionsResponse, -- ** ListConfigurations (Paginated) ListConfigurations (ListConfigurations'), newListConfigurations, ListConfigurationsResponse (ListConfigurationsResponse'), newListConfigurationsResponse, -- ** ListKafkaVersions (Paginated) ListKafkaVersions (ListKafkaVersions'), newListKafkaVersions, ListKafkaVersionsResponse (ListKafkaVersionsResponse'), newListKafkaVersionsResponse, -- ** ListNodes (Paginated) ListNodes (ListNodes'), newListNodes, ListNodesResponse (ListNodesResponse'), newListNodesResponse, -- ** ListScramSecrets (Paginated) ListScramSecrets (ListScramSecrets'), newListScramSecrets, ListScramSecretsResponse (ListScramSecretsResponse'), newListScramSecretsResponse, -- ** ListTagsForResource ListTagsForResource (ListTagsForResource'), newListTagsForResource, ListTagsForResourceResponse (ListTagsForResourceResponse'), newListTagsForResourceResponse, -- ** RebootBroker RebootBroker (RebootBroker'), newRebootBroker, RebootBrokerResponse (RebootBrokerResponse'), newRebootBrokerResponse, -- ** TagResource TagResource (TagResource'), newTagResource, TagResourceResponse (TagResourceResponse'), newTagResourceResponse, -- ** UntagResource UntagResource (UntagResource'), newUntagResource, UntagResourceResponse (UntagResourceResponse'), newUntagResourceResponse, -- ** UpdateBrokerCount UpdateBrokerCount (UpdateBrokerCount'), newUpdateBrokerCount, UpdateBrokerCountResponse (UpdateBrokerCountResponse'), newUpdateBrokerCountResponse, -- ** UpdateBrokerStorage UpdateBrokerStorage (UpdateBrokerStorage'), newUpdateBrokerStorage, UpdateBrokerStorageResponse (UpdateBrokerStorageResponse'), newUpdateBrokerStorageResponse, -- ** UpdateBrokerType UpdateBrokerType (UpdateBrokerType'), newUpdateBrokerType, UpdateBrokerTypeResponse (UpdateBrokerTypeResponse'), newUpdateBrokerTypeResponse, -- ** UpdateClusterConfiguration UpdateClusterConfiguration (UpdateClusterConfiguration'), newUpdateClusterConfiguration, UpdateClusterConfigurationResponse (UpdateClusterConfigurationResponse'), newUpdateClusterConfigurationResponse, -- ** UpdateClusterKafkaVersion UpdateClusterKafkaVersion (UpdateClusterKafkaVersion'), newUpdateClusterKafkaVersion, UpdateClusterKafkaVersionResponse (UpdateClusterKafkaVersionResponse'), newUpdateClusterKafkaVersionResponse, -- ** UpdateConfiguration UpdateConfiguration (UpdateConfiguration'), newUpdateConfiguration, UpdateConfigurationResponse (UpdateConfigurationResponse'), newUpdateConfigurationResponse, -- ** UpdateConnectivity UpdateConnectivity (UpdateConnectivity'), newUpdateConnectivity, UpdateConnectivityResponse (UpdateConnectivityResponse'), newUpdateConnectivityResponse, -- ** UpdateMonitoring UpdateMonitoring (UpdateMonitoring'), newUpdateMonitoring, UpdateMonitoringResponse (UpdateMonitoringResponse'), newUpdateMonitoringResponse, -- ** UpdateSecurity UpdateSecurity (UpdateSecurity'), newUpdateSecurity, UpdateSecurityResponse (UpdateSecurityResponse'), newUpdateSecurityResponse, -- ** UpdateStorage UpdateStorage (UpdateStorage'), newUpdateStorage, UpdateStorageResponse (UpdateStorageResponse'), newUpdateStorageResponse, -- * Types -- ** BrokerAZDistribution BrokerAZDistribution (..), -- ** ClientBroker ClientBroker (..), -- ** ClusterState ClusterState (..), -- ** ClusterType ClusterType (..), -- ** ConfigurationState ConfigurationState (..), -- ** EnhancedMonitoring EnhancedMonitoring (..), -- ** KafkaVersionStatus KafkaVersionStatus (..), -- ** NodeType NodeType (..), -- ** StorageMode StorageMode (..), -- ** BrokerEBSVolumeInfo BrokerEBSVolumeInfo (BrokerEBSVolumeInfo'), newBrokerEBSVolumeInfo, -- ** BrokerLogs BrokerLogs (BrokerLogs'), newBrokerLogs, -- ** BrokerNodeGroupInfo BrokerNodeGroupInfo (BrokerNodeGroupInfo'), newBrokerNodeGroupInfo, -- ** BrokerNodeInfo BrokerNodeInfo (BrokerNodeInfo'), newBrokerNodeInfo, -- ** BrokerSoftwareInfo BrokerSoftwareInfo (BrokerSoftwareInfo'), newBrokerSoftwareInfo, -- ** ClientAuthentication ClientAuthentication (ClientAuthentication'), newClientAuthentication, -- ** CloudWatchLogs CloudWatchLogs (CloudWatchLogs'), newCloudWatchLogs, -- ** Cluster Cluster (Cluster'), newCluster, -- ** ClusterInfo ClusterInfo (ClusterInfo'), newClusterInfo, -- ** ClusterOperationInfo ClusterOperationInfo (ClusterOperationInfo'), newClusterOperationInfo, -- ** ClusterOperationStep ClusterOperationStep (ClusterOperationStep'), newClusterOperationStep, -- ** ClusterOperationStepInfo ClusterOperationStepInfo (ClusterOperationStepInfo'), newClusterOperationStepInfo, -- ** CompatibleKafkaVersion CompatibleKafkaVersion (CompatibleKafkaVersion'), newCompatibleKafkaVersion, -- ** Configuration Configuration (Configuration'), newConfiguration, -- ** ConfigurationInfo ConfigurationInfo (ConfigurationInfo'), newConfigurationInfo, -- ** ConfigurationRevision ConfigurationRevision (ConfigurationRevision'), newConfigurationRevision, -- ** ConnectivityInfo ConnectivityInfo (ConnectivityInfo'), newConnectivityInfo, -- ** EBSStorageInfo EBSStorageInfo (EBSStorageInfo'), newEBSStorageInfo, -- ** EncryptionAtRest EncryptionAtRest (EncryptionAtRest'), newEncryptionAtRest, -- ** EncryptionInTransit EncryptionInTransit (EncryptionInTransit'), newEncryptionInTransit, -- ** EncryptionInfo EncryptionInfo (EncryptionInfo'), newEncryptionInfo, -- ** ErrorInfo ErrorInfo (ErrorInfo'), newErrorInfo, -- ** Firehose Firehose (Firehose'), newFirehose, -- ** Iam Iam (Iam'), newIam, -- ** JmxExporter JmxExporter (JmxExporter'), newJmxExporter, -- ** JmxExporterInfo JmxExporterInfo (JmxExporterInfo'), newJmxExporterInfo, -- ** KafkaVersion KafkaVersion (KafkaVersion'), newKafkaVersion, -- ** LoggingInfo LoggingInfo (LoggingInfo'), newLoggingInfo, -- ** MutableClusterInfo MutableClusterInfo (MutableClusterInfo'), newMutableClusterInfo, -- ** NodeExporter NodeExporter (NodeExporter'), newNodeExporter, -- ** NodeExporterInfo NodeExporterInfo (NodeExporterInfo'), newNodeExporterInfo, -- ** NodeInfo NodeInfo (NodeInfo'), newNodeInfo, -- ** OpenMonitoring OpenMonitoring (OpenMonitoring'), newOpenMonitoring, -- ** OpenMonitoringInfo OpenMonitoringInfo (OpenMonitoringInfo'), newOpenMonitoringInfo, -- ** Prometheus Prometheus (Prometheus'), newPrometheus, -- ** PrometheusInfo PrometheusInfo (PrometheusInfo'), newPrometheusInfo, -- ** Provisioned Provisioned (Provisioned'), newProvisioned, -- ** ProvisionedRequest ProvisionedRequest (ProvisionedRequest'), newProvisionedRequest, -- ** ProvisionedThroughput ProvisionedThroughput (ProvisionedThroughput'), newProvisionedThroughput, -- ** PublicAccess PublicAccess (PublicAccess'), newPublicAccess, -- ** S3 S3 (S3'), newS3, -- ** Sasl Sasl (Sasl'), newSasl, -- ** Scram Scram (Scram'), newScram, -- ** Serverless Serverless (Serverless'), newServerless, -- ** ServerlessClientAuthentication ServerlessClientAuthentication (ServerlessClientAuthentication'), newServerlessClientAuthentication, -- ** ServerlessRequest ServerlessRequest (ServerlessRequest'), newServerlessRequest, -- ** ServerlessSasl ServerlessSasl (ServerlessSasl'), newServerlessSasl, -- ** StateInfo StateInfo (StateInfo'), newStateInfo, -- ** StorageInfo StorageInfo (StorageInfo'), newStorageInfo, -- ** Tls Tls (Tls'), newTls, -- ** Unauthenticated Unauthenticated (Unauthenticated'), newUnauthenticated, -- ** UnprocessedScramSecret UnprocessedScramSecret (UnprocessedScramSecret'), newUnprocessedScramSecret, -- ** VpcConfig VpcConfig (VpcConfig'), newVpcConfig, -- ** ZookeeperNodeInfo ZookeeperNodeInfo (ZookeeperNodeInfo'), newZookeeperNodeInfo, ) where import Amazonka.Kafka.BatchAssociateScramSecret import Amazonka.Kafka.BatchDisassociateScramSecret import Amazonka.Kafka.CreateCluster import Amazonka.Kafka.CreateClusterV2 import Amazonka.Kafka.CreateConfiguration import Amazonka.Kafka.DeleteCluster import Amazonka.Kafka.DeleteConfiguration import Amazonka.Kafka.DescribeCluster import Amazonka.Kafka.DescribeClusterOperation import Amazonka.Kafka.DescribeClusterV2 import Amazonka.Kafka.DescribeConfiguration import Amazonka.Kafka.DescribeConfigurationRevision import Amazonka.Kafka.GetBootstrapBrokers import Amazonka.Kafka.GetCompatibleKafkaVersions import Amazonka.Kafka.Lens import Amazonka.Kafka.ListClusterOperations import Amazonka.Kafka.ListClusters import Amazonka.Kafka.ListClustersV2 import Amazonka.Kafka.ListConfigurationRevisions import Amazonka.Kafka.ListConfigurations import Amazonka.Kafka.ListKafkaVersions import Amazonka.Kafka.ListNodes import Amazonka.Kafka.ListScramSecrets import Amazonka.Kafka.ListTagsForResource import Amazonka.Kafka.RebootBroker import Amazonka.Kafka.TagResource import Amazonka.Kafka.Types import Amazonka.Kafka.UntagResource import Amazonka.Kafka.UpdateBrokerCount import Amazonka.Kafka.UpdateBrokerStorage import Amazonka.Kafka.UpdateBrokerType import Amazonka.Kafka.UpdateClusterConfiguration import Amazonka.Kafka.UpdateClusterKafkaVersion import Amazonka.Kafka.UpdateConfiguration import Amazonka.Kafka.UpdateConnectivity import Amazonka.Kafka.UpdateMonitoring import Amazonka.Kafka.UpdateSecurity import Amazonka.Kafka.UpdateStorage import Amazonka.Kafka.Waiters -- $errors -- Error matchers are designed for use with the functions provided by -- . -- This allows catching (and rethrowing) service specific errors returned -- by 'Kafka'. -- $operations -- Some AWS operations return results that are incomplete and require subsequent -- requests in order to obtain the entire result set. The process of sending -- subsequent requests to continue where a previous request left off is called -- pagination. For example, the 'ListObjects' operation of Amazon S3 returns up to -- 1000 objects at a time, and you must send subsequent requests with the -- appropriate Marker in order to retrieve the next page of results. -- -- Operations that have an 'AWSPager' instance can transparently perform subsequent -- requests, correctly setting Markers and other request facets to iterate through -- the entire result set of a truncated API operation. Operations which support -- this have an additional note in the documentation. -- -- Many operations have the ability to filter results on the server side. See the -- individual operation parameters for details. -- $waiters -- Waiters poll by repeatedly sending a request until some remote success condition -- configured by the 'Wait' specification is fulfilled. The 'Wait' specification -- determines how many attempts should be made, in addition to delay and retry strategies.