Awso_kafka_lwt (p.awso-lwt.0.9.1.doc.awso-lwt.kafka.Awso_kafka

Source

val batch_associate_scram_secret : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.BatchAssociateScramSecretRequest.t ->
  (Awso_kafka.Values.BatchAssociateScramSecretResponse.t,
    Awso_kafka.Values.BatchAssociateScramSecretResponse.error)
    Result.t
    Lwt.t

Source

val create_cluster : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.CreateClusterRequest.t ->
  (Awso_kafka.Values.CreateClusterResponse.t,
    Awso_kafka.Values.CreateClusterResponse.error)
    Result.t
    Lwt.t

Source

val create_cluster_v2 : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.CreateClusterV2Request.t ->
  (Awso_kafka.Values.CreateClusterV2Response.t,
    Awso_kafka.Values.CreateClusterV2Response.error)
    Result.t
    Lwt.t

Source

val create_configuration : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.CreateConfigurationRequest.t ->
  (Awso_kafka.Values.CreateConfigurationResponse.t,
    Awso_kafka.Values.CreateConfigurationResponse.error)
    Result.t
    Lwt.t

Source

val create_replicator : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.CreateReplicatorRequest.t ->
  (Awso_kafka.Values.CreateReplicatorResponse.t,
    Awso_kafka.Values.CreateReplicatorResponse.error)
    Result.t
    Lwt.t

Source

val create_topic : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.CreateTopicRequest.t ->
  (Awso_kafka.Values.CreateTopicResponse.t,
    Awso_kafka.Values.CreateTopicResponse.error)
    Result.t
    Lwt.t

Source

val create_vpc_connection : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.CreateVpcConnectionRequest.t ->
  (Awso_kafka.Values.CreateVpcConnectionResponse.t,
    Awso_kafka.Values.CreateVpcConnectionResponse.error)
    Result.t
    Lwt.t

Source

val delete_cluster : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DeleteClusterRequest.t ->
  (Awso_kafka.Values.DeleteClusterResponse.t,
    Awso_kafka.Values.DeleteClusterResponse.error)
    Result.t
    Lwt.t

Source

val delete_cluster_policy : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DeleteClusterPolicyRequest.t ->
  (Awso_kafka.Values.DeleteClusterPolicyResponse.t,
    Awso_kafka.Values.DeleteClusterPolicyResponse.error)
    Result.t
    Lwt.t

Source

val delete_configuration : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DeleteConfigurationRequest.t ->
  (Awso_kafka.Values.DeleteConfigurationResponse.t,
    Awso_kafka.Values.DeleteConfigurationResponse.error)
    Result.t
    Lwt.t

Source

val delete_replicator : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DeleteReplicatorRequest.t ->
  (Awso_kafka.Values.DeleteReplicatorResponse.t,
    Awso_kafka.Values.DeleteReplicatorResponse.error)
    Result.t
    Lwt.t

Source

val delete_topic : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DeleteTopicRequest.t ->
  (Awso_kafka.Values.DeleteTopicResponse.t,
    Awso_kafka.Values.DeleteTopicResponse.error)
    Result.t
    Lwt.t

Source

val delete_vpc_connection : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DeleteVpcConnectionRequest.t ->
  (Awso_kafka.Values.DeleteVpcConnectionResponse.t,
    Awso_kafka.Values.DeleteVpcConnectionResponse.error)
    Result.t
    Lwt.t

Source

val describe_cluster : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeClusterRequest.t ->
  (Awso_kafka.Values.DescribeClusterResponse.t,
    Awso_kafka.Values.DescribeClusterResponse.error)
    Result.t
    Lwt.t

Source

val describe_cluster_v2 : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeClusterV2Request.t ->
  (Awso_kafka.Values.DescribeClusterV2Response.t,
    Awso_kafka.Values.DescribeClusterV2Response.error)
    Result.t
    Lwt.t

Source

val describe_cluster_operation : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeClusterOperationRequest.t ->
  (Awso_kafka.Values.DescribeClusterOperationResponse.t,
    Awso_kafka.Values.DescribeClusterOperationResponse.error)
    Result.t
    Lwt.t

Source

val describe_cluster_operation_v2 : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeClusterOperationV2Request.t ->
  (Awso_kafka.Values.DescribeClusterOperationV2Response.t,
    Awso_kafka.Values.DescribeClusterOperationV2Response.error)
    Result.t
    Lwt.t

Source

val describe_configuration : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeConfigurationRequest.t ->
  (Awso_kafka.Values.DescribeConfigurationResponse.t,
    Awso_kafka.Values.DescribeConfigurationResponse.error)
    Result.t
    Lwt.t

Source

val describe_configuration_revision : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeConfigurationRevisionRequest.t ->
  (Awso_kafka.Values.DescribeConfigurationRevisionResponse.t,
    Awso_kafka.Values.DescribeConfigurationRevisionResponse.error)
    Result.t
    Lwt.t

Source

val describe_replicator : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeReplicatorRequest.t ->
  (Awso_kafka.Values.DescribeReplicatorResponse.t,
    Awso_kafka.Values.DescribeReplicatorResponse.error)
    Result.t
    Lwt.t

Source

val describe_topic : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeTopicRequest.t ->
  (Awso_kafka.Values.DescribeTopicResponse.t,
    Awso_kafka.Values.DescribeTopicResponse.error)
    Result.t
    Lwt.t

Source

val describe_topic_partitions : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeTopicPartitionsRequest.t ->
  (Awso_kafka.Values.DescribeTopicPartitionsResponse.t,
    Awso_kafka.Values.DescribeTopicPartitionsResponse.error)
    Result.t
    Lwt.t

Source

val describe_vpc_connection : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.DescribeVpcConnectionRequest.t ->
  (Awso_kafka.Values.DescribeVpcConnectionResponse.t,
    Awso_kafka.Values.DescribeVpcConnectionResponse.error)
    Result.t
    Lwt.t

Source

val batch_disassociate_scram_secret : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.BatchDisassociateScramSecretRequest.t ->
  (Awso_kafka.Values.BatchDisassociateScramSecretResponse.t,
    Awso_kafka.Values.BatchDisassociateScramSecretResponse.error)
    Result.t
    Lwt.t

Source

val get_bootstrap_brokers : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.GetBootstrapBrokersRequest.t ->
  (Awso_kafka.Values.GetBootstrapBrokersResponse.t,
    Awso_kafka.Values.GetBootstrapBrokersResponse.error)
    Result.t
    Lwt.t

Source

val get_compatible_kafka_versions : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.GetCompatibleKafkaVersionsRequest.t ->
  (Awso_kafka.Values.GetCompatibleKafkaVersionsResponse.t,
    Awso_kafka.Values.GetCompatibleKafkaVersionsResponse.error)
    Result.t
    Lwt.t

Source

val get_cluster_policy : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.GetClusterPolicyRequest.t ->
  (Awso_kafka.Values.GetClusterPolicyResponse.t,
    Awso_kafka.Values.GetClusterPolicyResponse.error)
    Result.t
    Lwt.t

Source

val list_cluster_operations : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListClusterOperationsRequest.t ->
  (Awso_kafka.Values.ListClusterOperationsResponse.t,
    Awso_kafka.Values.ListClusterOperationsResponse.error)
    Result.t
    Lwt.t

Source

val list_cluster_operations_v2 : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListClusterOperationsV2Request.t ->
  (Awso_kafka.Values.ListClusterOperationsV2Response.t,
    Awso_kafka.Values.ListClusterOperationsV2Response.error)
    Result.t
    Lwt.t

Source

val list_clusters : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListClustersRequest.t ->
  (Awso_kafka.Values.ListClustersResponse.t,
    Awso_kafka.Values.ListClustersResponse.error)
    Result.t
    Lwt.t

Source

val list_clusters_v2 : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListClustersV2Request.t ->
  (Awso_kafka.Values.ListClustersV2Response.t,
    Awso_kafka.Values.ListClustersV2Response.error)
    Result.t
    Lwt.t

Source

val list_configuration_revisions : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListConfigurationRevisionsRequest.t ->
  (Awso_kafka.Values.ListConfigurationRevisionsResponse.t,
    Awso_kafka.Values.ListConfigurationRevisionsResponse.error)
    Result.t
    Lwt.t

Source

val list_configurations : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListConfigurationsRequest.t ->
  (Awso_kafka.Values.ListConfigurationsResponse.t,
    Awso_kafka.Values.ListConfigurationsResponse.error)
    Result.t
    Lwt.t

Source

val list_kafka_versions : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListKafkaVersionsRequest.t ->
  (Awso_kafka.Values.ListKafkaVersionsResponse.t,
    Awso_kafka.Values.ListKafkaVersionsResponse.error)
    Result.t
    Lwt.t

Source

val list_nodes : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListNodesRequest.t ->
  (Awso_kafka.Values.ListNodesResponse.t,
    Awso_kafka.Values.ListNodesResponse.error)
    Result.t
    Lwt.t

Source

val list_replicators : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListReplicatorsRequest.t ->
  (Awso_kafka.Values.ListReplicatorsResponse.t,
    Awso_kafka.Values.ListReplicatorsResponse.error)
    Result.t
    Lwt.t

Source

val list_scram_secrets : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListScramSecretsRequest.t ->
  (Awso_kafka.Values.ListScramSecretsResponse.t,
    Awso_kafka.Values.ListScramSecretsResponse.error)
    Result.t
    Lwt.t

Source

val list_tags_for_resource : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListTagsForResourceRequest.t ->
  (Awso_kafka.Values.ListTagsForResourceResponse.t,
    Awso_kafka.Values.ListTagsForResourceResponse.error)
    Result.t
    Lwt.t

Source

val list_client_vpc_connections : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListClientVpcConnectionsRequest.t ->
  (Awso_kafka.Values.ListClientVpcConnectionsResponse.t,
    Awso_kafka.Values.ListClientVpcConnectionsResponse.error)
    Result.t
    Lwt.t

Source

val list_topics : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListTopicsRequest.t ->
  (Awso_kafka.Values.ListTopicsResponse.t,
    Awso_kafka.Values.ListTopicsResponse.error)
    Result.t
    Lwt.t

Source

val list_vpc_connections : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.ListVpcConnectionsRequest.t ->
  (Awso_kafka.Values.ListVpcConnectionsResponse.t,
    Awso_kafka.Values.ListVpcConnectionsResponse.error)
    Result.t
    Lwt.t

Source

val reject_client_vpc_connection : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.RejectClientVpcConnectionRequest.t ->
  (Awso_kafka.Values.RejectClientVpcConnectionResponse.t,
    Awso_kafka.Values.RejectClientVpcConnectionResponse.error)
    Result.t
    Lwt.t

Source

val put_cluster_policy : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.PutClusterPolicyRequest.t ->
  (Awso_kafka.Values.PutClusterPolicyResponse.t,
    Awso_kafka.Values.PutClusterPolicyResponse.error)
    Result.t
    Lwt.t

Source

val reboot_broker : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.RebootBrokerRequest.t ->
  (Awso_kafka.Values.RebootBrokerResponse.t,
    Awso_kafka.Values.RebootBrokerResponse.error)
    Result.t
    Lwt.t

Source

val tag_resource : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.TagResourceRequest.t ->
  (unit, unit) Result.t Lwt.t

Source

val untag_resource : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UntagResourceRequest.t ->
  (unit, unit) Result.t Lwt.t

Source

val update_broker_count : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateBrokerCountRequest.t ->
  (Awso_kafka.Values.UpdateBrokerCountResponse.t,
    Awso_kafka.Values.UpdateBrokerCountResponse.error)
    Result.t
    Lwt.t

Source

val update_broker_type : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateBrokerTypeRequest.t ->
  (Awso_kafka.Values.UpdateBrokerTypeResponse.t,
    Awso_kafka.Values.UpdateBrokerTypeResponse.error)
    Result.t
    Lwt.t

Source

val update_broker_storage : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateBrokerStorageRequest.t ->
  (Awso_kafka.Values.UpdateBrokerStorageResponse.t,
    Awso_kafka.Values.UpdateBrokerStorageResponse.error)
    Result.t
    Lwt.t

Source

val update_configuration : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateConfigurationRequest.t ->
  (Awso_kafka.Values.UpdateConfigurationResponse.t,
    Awso_kafka.Values.UpdateConfigurationResponse.error)
    Result.t
    Lwt.t

Source

val update_connectivity : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateConnectivityRequest.t ->
  (Awso_kafka.Values.UpdateConnectivityResponse.t,
    Awso_kafka.Values.UpdateConnectivityResponse.error)
    Result.t
    Lwt.t

Source

val update_cluster_configuration : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateClusterConfigurationRequest.t ->
  (Awso_kafka.Values.UpdateClusterConfigurationResponse.t,
    Awso_kafka.Values.UpdateClusterConfigurationResponse.error)
    Result.t
    Lwt.t

Source

val update_cluster_kafka_version : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateClusterKafkaVersionRequest.t ->
  (Awso_kafka.Values.UpdateClusterKafkaVersionResponse.t,
    Awso_kafka.Values.UpdateClusterKafkaVersionResponse.error)
    Result.t
    Lwt.t

Source

val update_monitoring : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateMonitoringRequest.t ->
  (Awso_kafka.Values.UpdateMonitoringResponse.t,
    Awso_kafka.Values.UpdateMonitoringResponse.error)
    Result.t
    Lwt.t

Source

val update_rebalancing : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateRebalancingRequest.t ->
  (Awso_kafka.Values.UpdateRebalancingResponse.t,
    Awso_kafka.Values.UpdateRebalancingResponse.error)
    Result.t
    Lwt.t

Source

val update_replication_info : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateReplicationInfoRequest.t ->
  (Awso_kafka.Values.UpdateReplicationInfoResponse.t,
    Awso_kafka.Values.UpdateReplicationInfoResponse.error)
    Result.t
    Lwt.t

Source

val update_security : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateSecurityRequest.t ->
  (Awso_kafka.Values.UpdateSecurityResponse.t,
    Awso_kafka.Values.UpdateSecurityResponse.error)
    Result.t
    Lwt.t

Source

val update_storage : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateStorageRequest.t ->
  (Awso_kafka.Values.UpdateStorageResponse.t,
    Awso_kafka.Values.UpdateStorageResponse.error)
    Result.t
    Lwt.t

Source

val update_topic : 
  ?endpoint_url:string ->
  ?cfg:Awso.Cfg.t ->
  Awso_kafka.Values.UpdateTopicRequest.t ->
  (Awso_kafka.Values.UpdateTopicResponse.t,
    Awso_kafka.Values.UpdateTopicResponse.error)
    Result.t
    Lwt.t

include module type of struct include Awso_kafka.Values end

Sourceval service : Awso.Service.t

Sourceval apiVersion : string

Sourceval endpointPrefix : string

Sourceval serviceFullName : string

Sourceval signatureVersion : string

Sourceval protocol : string

Sourceval globalEndpoint : string

Sourceval serviceAbbreviation : string

Sourceval simple_to_json : ('a -> Awso__Botodata.value) -> 'a -> Yojson.Safe.t

Sourceval composed_to_json : ('a -> Awso__Botodata.value) -> 'a -> Yojson.Safe.t

Sourceval to_query : ('a -> Awso.Client.Query.value) -> 'a -> Awso.Client.Query.t

Source

val structure_to_value_aux : 
  ('a * 'b option) list ->
  f:(('a * 'b) list -> 'c) ->
  [> `Structure of 'c ]

Source

val structure_to_value : 
  ('a * 'b option) list ->
  [> `Structure of ('a * 'b) list ]

Source

val structure_to_wrapped_value : 
  wrapper:'a ->
  response:'a ->
  ('b * 'c option) list ->
  [> `Structure of ('a * [> `Structure of ('b * 'c) list ]) list ]

Sourcemodule VpcConnectivityIam = Awso_kafka.Values.VpcConnectivityIam

Details for IAM access control for VPC connectivity.

Sourcemodule VpcConnectivityScram = Awso_kafka.Values.VpcConnectivityScram

Details for SASL/SCRAM client authentication for VPC connectivity.

Sourcemodule VpcConnectivitySasl = Awso_kafka.Values.VpcConnectivitySasl

Details for SASL client authentication for VPC connectivity.

Sourcemodule VpcConnectivityTls = Awso_kafka.Values.VpcConnectivityTls

Details for TLS client authentication for VPC connectivity.

Source

module VpcConnectivityClientAuthentication =
  Awso_kafka.Values.VpcConnectivityClientAuthentication

Includes all client authentication information for VPC connectivity.

Sourcemodule ProvisionedThroughput = Awso_kafka.Values.ProvisionedThroughput

Contains information about provisioned throughput for EBS storage volumes attached to kafka broker nodes.

Sourcemodule NetworkType = Awso_kafka.Values.NetworkType

Sourcemodule PublicAccess = Awso_kafka.Values.PublicAccess

Public access control for brokers.

Sourcemodule VpcConnectivity = Awso_kafka.Values.VpcConnectivity

VPC connectivity access control for brokers.

Sourcemodule EBSStorageInfo = Awso_kafka.Values.EBSStorageInfo

Contains information about the EBS storage volumes attached to Apache Kafka broker nodes.

Sourcemodule Iam = Awso_kafka.Values.Iam

Details for IAM access control.

Sourcemodule Scram = Awso_kafka.Values.Scram

Details for SASL/SCRAM client authentication.

Sourcemodule ClientBroker = Awso_kafka.Values.ClientBroker

Sourcemodule CloudWatchLogs = Awso_kafka.Values.CloudWatchLogs

Sourcemodule Firehose = Awso_kafka.Values.Firehose

Sourcemodule S3 = Awso_kafka.Values.S3

Sourcemodule JmxExporterInfo = Awso_kafka.Values.JmxExporterInfo

Indicates whether you want to turn on or turn off the JMX Exporter.

Sourcemodule NodeExporterInfo = Awso_kafka.Values.NodeExporterInfo

Indicates whether you want to turn on or turn off the Node Exporter.

Sourcemodule JmxExporter = Awso_kafka.Values.JmxExporter

Indicates whether you want to turn on or turn off the JMX Exporter.

Sourcemodule NodeExporter = Awso_kafka.Values.NodeExporter

Indicates whether you want to turn on or turn off the Node Exporter.

Sourcemodule AmazonMskCluster = Awso_kafka.Values.AmazonMskCluster

Details of an Amazon MSK Cluster.

Sourcemodule ApacheKafkaCluster = Awso_kafka.Values.ApacheKafkaCluster

Details of an Apache Kafka Cluster.

Sourcemodule BrokerAZDistribution = Awso_kafka.Values.BrokerAZDistribution

Sourcemodule ConnectivityInfo = Awso_kafka.Values.ConnectivityInfo

Information about the broker access configuration.

Sourcemodule StorageInfo = Awso_kafka.Values.StorageInfo

Contains information about storage volumes attached to MSK broker nodes.

Sourcemodule Sasl = Awso_kafka.Values.Sasl

Details for client authentication using SASL.

Sourcemodule Tls = Awso_kafka.Values.Tls

Details for client authentication using TLS.

Sourcemodule Unauthenticated = Awso_kafka.Values.Unauthenticated

Sourcemodule EncryptionAtRest = Awso_kafka.Values.EncryptionAtRest

The data-volume encryption details.

Sourcemodule EncryptionInTransit = Awso_kafka.Values.EncryptionInTransit

The settings for encrypting data in transit.

Sourcemodule BrokerLogs = Awso_kafka.Values.BrokerLogs

Sourcemodule PrometheusInfo = Awso_kafka.Values.PrometheusInfo

Prometheus settings.

Sourcemodule RebalancingStatus = Awso_kafka.Values.RebalancingStatus

Sourcemodule ServerlessSasl = Awso_kafka.Values.ServerlessSasl

Details for client authentication using SASL.

Sourcemodule VpcConfig = Awso_kafka.Values.VpcConfig

The configuration of the Amazon VPCs for the cluster.

Sourcemodule Prometheus = Awso_kafka.Values.Prometheus

Prometheus settings.

Sourcemodule BrokerEBSVolumeInfo = Awso_kafka.Values.BrokerEBSVolumeInfo

Specifies the EBS volume upgrade information. The broker identifier must be set to the keyword ALL. This means the changes apply to all the brokers in the cluster.

Sourcemodule UserIdentityType = Awso_kafka.Values.UserIdentityType

Sourcemodule ClusterOperationStepInfo = Awso_kafka.Values.ClusterOperationStepInfo

State information about the operation step.

Source

module KafkaClusterSaslScramMechanism =
  Awso_kafka.Values.KafkaClusterSaslScramMechanism

Source

module ReplicationStartingPositionType =
  Awso_kafka.Values.ReplicationStartingPositionType

Source

module ReplicationTopicNameConfigurationType =
  Awso_kafka.Values.ReplicationTopicNameConfigurationType

Sourcemodule KafkaClusterSummary = Awso_kafka.Values.KafkaClusterSummary

Summarized information about Kafka Cluster used as source / target for replication.

Sourcemodule ReplicationInfoSummary = Awso_kafka.Values.ReplicationInfoSummary

Summarized information of replication between clusters.

Sourcemodule BrokerSoftwareInfo = Awso_kafka.Values.BrokerSoftwareInfo

Information about the current software installed on the cluster.

Sourcemodule BrokerNodeGroupInfo = Awso_kafka.Values.BrokerNodeGroupInfo

Describes the setup to be used for Apache Kafka broker nodes in the cluster.

Sourcemodule ClientAuthentication = Awso_kafka.Values.ClientAuthentication

Includes all client authentication information.

Sourcemodule CustomerActionStatus = Awso_kafka.Values.CustomerActionStatus

Sourcemodule EncryptionInfo = Awso_kafka.Values.EncryptionInfo

Includes encryption-related information, such as the AWS KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit.

Sourcemodule EnhancedMonitoring = Awso_kafka.Values.EnhancedMonitoring

Sourcemodule LoggingInfo = Awso_kafka.Values.LoggingInfo

Sourcemodule OpenMonitoringInfo = Awso_kafka.Values.OpenMonitoringInfo

JMX and Node monitoring for the MSK cluster.

Sourcemodule Rebalancing = Awso_kafka.Values.Rebalancing

Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.

Sourcemodule StorageMode = Awso_kafka.Values.StorageMode

Source

module ServerlessClientAuthentication =
  Awso_kafka.Values.ServerlessClientAuthentication

Includes all client authentication information.

Source

module ServerlessConnectivityInfo =
  Awso_kafka.Values.ServerlessConnectivityInfo

Describes the cluster's connectivity information, such as its network type, which is IPv4 or DUAL.

Sourcemodule BrokerCountUpdateInfo = Awso_kafka.Values.BrokerCountUpdateInfo

Information regarding UpdateBrokerCount.

Sourcemodule ConfigurationInfo = Awso_kafka.Values.ConfigurationInfo

Specifies the configuration to use for the brokers.

Sourcemodule OpenMonitoring = Awso_kafka.Values.OpenMonitoring

JMX and Node monitoring for the MSK cluster.

Sourcemodule ZookeeperAccess = Awso_kafka.Values.ZookeeperAccess

Access control settings for zookeeper

Sourcemodule UserIdentity = Awso_kafka.Values.UserIdentity

Description of the requester that calls the API operation.

Sourcemodule ClusterOperationStep = Awso_kafka.Values.ClusterOperationStep

Step taken during a cluster operation.

Source

module KafkaClusterSaslScramAuthentication =
  Awso_kafka.Values.KafkaClusterSaslScramAuthentication

Details for SASL/SCRAM client authentication.

Source

module KafkaClusterEncryptionInTransitType =
  Awso_kafka.Values.KafkaClusterEncryptionInTransitType

Source

module ConsumerGroupOffsetSyncMode =
  Awso_kafka.Values.ConsumerGroupOffsetSyncMode

Source

module ReplicationStartingPosition =
  Awso_kafka.Values.ReplicationStartingPosition

Configuration for specifying the position in the topics to start replicating from.

Source

module ReplicationTopicNameConfiguration =
  Awso_kafka.Values.ReplicationTopicNameConfiguration

Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.

Sourcemodule ReplicatorCloudWatchLogs = Awso_kafka.Values.ReplicatorCloudWatchLogs

Details about delivering logs to CloudWatch Logs.

Sourcemodule ReplicatorFirehose = Awso_kafka.Values.ReplicatorFirehose

Details about delivering logs to Firehose.

Sourcemodule ReplicatorS3 = Awso_kafka.Values.ReplicatorS3

Details about delivering logs to S3.

Sourcemodule VpcConnectionState = Awso_kafka.Values.VpcConnectionState

Sourcemodule ReplicatorState = Awso_kafka.Values.ReplicatorState

Sourcemodule BrokerNodeInfo = Awso_kafka.Values.BrokerNodeInfo

BrokerNodeInfo

Sourcemodule ControllerNodeInfo = Awso_kafka.Values.ControllerNodeInfo

Controller node information.

Sourcemodule NodeType = Awso_kafka.Values.NodeType

Sourcemodule ZookeeperNodeInfo = Awso_kafka.Values.ZookeeperNodeInfo

Zookeeper node information.

Sourcemodule KafkaVersionStatus = Awso_kafka.Values.KafkaVersionStatus

Sourcemodule ConfigurationRevision = Awso_kafka.Values.ConfigurationRevision

Describes a configuration revision.

Sourcemodule ConfigurationState = Awso_kafka.Values.ConfigurationState

Sourcemodule ClusterState = Awso_kafka.Values.ClusterState

Sourcemodule ClusterType = Awso_kafka.Values.ClusterType

Sourcemodule Provisioned = Awso_kafka.Values.Provisioned

Provisioned cluster.

Sourcemodule Serverless = Awso_kafka.Values.Serverless

Serverless cluster.

Sourcemodule StateInfo = Awso_kafka.Values.StateInfo

Sourcemodule ErrorInfo = Awso_kafka.Values.ErrorInfo

Returns information about an error state of the cluster.

Sourcemodule MutableClusterInfo = Awso_kafka.Values.MutableClusterInfo

Information about cluster attributes that can be updated via update APIs.

Sourcemodule VpcConnectionInfo = Awso_kafka.Values.VpcConnectionInfo

Description of the VPC connection.

Source

module KafkaClusterClientAuthentication =
  Awso_kafka.Values.KafkaClusterClientAuthentication

Details of the client authentication used by the Apache Kafka cluster.

Source

module KafkaClusterClientVpcConfig =
  Awso_kafka.Values.KafkaClusterClientVpcConfig

Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

Source

module KafkaClusterEncryptionInTransit =
  Awso_kafka.Values.KafkaClusterEncryptionInTransit

Details of encryption in transit to the Apache Kafka cluster.

Sourcemodule ConsumerGroupReplication = Awso_kafka.Values.ConsumerGroupReplication

Details about consumer group replication.

Sourcemodule TargetCompressionType = Awso_kafka.Values.TargetCompressionType

Sourcemodule TopicReplication = Awso_kafka.Values.TopicReplication

Details about topic replication.

Source

module VpcConnectionInfoServerless =
  Awso_kafka.Values.VpcConnectionInfoServerless

Description of the VPC connection.

Sourcemodule ReplicatorLogDelivery = Awso_kafka.Values.ReplicatorLogDelivery

Configuration for replicator log delivery.

Sourcemodule VpcConnection = Awso_kafka.Values.VpcConnection

The VPC connection object.

Sourcemodule TopicInfo = Awso_kafka.Values.TopicInfo

Includes identification info about the topic.

Sourcemodule ReplicatorSummary = Awso_kafka.Values.ReplicatorSummary

Information about a replicator.

Sourcemodule NodeInfo = Awso_kafka.Values.NodeInfo

The node information object.

Sourcemodule KafkaVersion = Awso_kafka.Values.KafkaVersion

Sourcemodule Configuration = Awso_kafka.Values.Configuration

Represents an MSK Configuration.

Sourcemodule Cluster = Awso_kafka.Values.Cluster

Returns information about a cluster.

Sourcemodule ClusterInfo = Awso_kafka.Values.ClusterInfo

Returns information about a cluster.

Sourcemodule ClusterOperationV2Summary = Awso_kafka.Values.ClusterOperationV2Summary

Returns information about a cluster operation.

Sourcemodule ClusterOperationInfo = Awso_kafka.Values.ClusterOperationInfo

Returns information about a cluster operation.

Sourcemodule ClientVpcConnection = Awso_kafka.Values.ClientVpcConnection

The client VPC connection object.

Sourcemodule CompatibleKafkaVersion = Awso_kafka.Values.CompatibleKafkaVersion

Contains source Apache Kafka versions and compatible target Apache Kafka versions.

Sourcemodule TopicPartitionInfo = Awso_kafka.Values.TopicPartitionInfo

Contains information about a topic partition.

Sourcemodule KafkaClusterDescription = Awso_kafka.Values.KafkaClusterDescription

Information about Kafka Cluster used as source / target for replication.

Source

module ReplicationInfoDescription =
  Awso_kafka.Values.ReplicationInfoDescription

Specifies configuration for replication between a source and target Kafka cluster (sourceKafkaClusterAlias -> targetKafkaClusterAlias)

Source

module ClusterOperationV2Provisioned =
  Awso_kafka.Values.ClusterOperationV2Provisioned

Returns information about a provisioned cluster operation.

Source

module ClusterOperationV2Serverless =
  Awso_kafka.Values.ClusterOperationV2Serverless

Returns information about a serverless cluster operation.

Sourcemodule KafkaCluster = Awso_kafka.Values.KafkaCluster

Information about Kafka Cluster to be used as source / target for replication.

Sourcemodule ReplicationInfo = Awso_kafka.Values.ReplicationInfo

Specifies configuration for replication between a source and target Kafka cluster.

Sourcemodule UnprocessedScramSecret = Awso_kafka.Values.UnprocessedScramSecret

Error info for scram secret associate/disassociate failure.

Sourcemodule BadRequestException = Awso_kafka.Values.BadRequestException

Returns information about an error.

Source

module ClusterConnectivityException =
  Awso_kafka.Values.ClusterConnectivityException

Returns information about an error.

Sourcemodule ControllerMovedException = Awso_kafka.Values.ControllerMovedException

Returns information about an error.

Sourcemodule ForbiddenException = Awso_kafka.Values.ForbiddenException

Returns information about an error.

Source

module GroupSubscribedToTopicException =
  Awso_kafka.Values.GroupSubscribedToTopicException

Returns information about an error.

Source

module InternalServerErrorException =
  Awso_kafka.Values.InternalServerErrorException

Returns information about an error.

Sourcemodule KafkaRequestException = Awso_kafka.Values.KafkaRequestException

Returns information about an error.

Sourcemodule KafkaTimeoutException = Awso_kafka.Values.KafkaTimeoutException

Returns information about an error.

Sourcemodule NotControllerException = Awso_kafka.Values.NotControllerException

Returns information about an error.

Sourcemodule NotFoundException = Awso_kafka.Values.NotFoundException

Returns information about an error.

Source

module ReassignmentInProgressException =
  Awso_kafka.Values.ReassignmentInProgressException

Returns information about an error.

Source

module ServiceUnavailableException =
  Awso_kafka.Values.ServiceUnavailableException

Returns information about an error.

Sourcemodule TopicState = Awso_kafka.Values.TopicState

Sourcemodule UnauthorizedException = Awso_kafka.Values.UnauthorizedException

Returns information about an error.

Source

module UnknownTopicOrPartitionException =
  Awso_kafka.Values.UnknownTopicOrPartitionException

Returns information about an error.

Sourcemodule TooManyRequestsException = Awso_kafka.Values.TooManyRequestsException

Returns information about an error.

Source

module ConsumerGroupReplicationUpdate =
  Awso_kafka.Values.ConsumerGroupReplicationUpdate

Details about consumer group replication.

Sourcemodule LogDelivery = Awso_kafka.Values.LogDelivery

Configuration for log delivery to customer destinations.

Sourcemodule TopicReplicationUpdate = Awso_kafka.Values.TopicReplicationUpdate

Details for updating the topic replication of a replicator.

Sourcemodule MaxResults = Awso_kafka.Values.MaxResults

Sourcemodule ConflictException = Awso_kafka.Values.ConflictException

Returns information about an error.

Sourcemodule ReplicationStateInfo = Awso_kafka.Values.ReplicationStateInfo

Details about the state of a replicator

Sourcemodule ClusterOperationV2 = Awso_kafka.Values.ClusterOperationV2

Returns information about a cluster operation.

Sourcemodule TopicExistsException = Awso_kafka.Values.TopicExistsException

Returns information about an error.

Sourcemodule ProvisionedRequest = Awso_kafka.Values.ProvisionedRequest

Provisioned cluster request.

Sourcemodule ServerlessRequest = Awso_kafka.Values.ServerlessRequest

Serverless cluster request.

Sourcemodule UpdateTopicResponse = Awso_kafka.Values.UpdateTopicResponse

Updates the configuration of the specified topic.

Sourcemodule UpdateTopicRequest = Awso_kafka.Values.UpdateTopicRequest

Updates the configuration of the specified topic.

Sourcemodule UpdateStorageResponse = Awso_kafka.Values.UpdateStorageResponse

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

Sourcemodule UpdateStorageRequest = Awso_kafka.Values.UpdateStorageRequest

Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.

Sourcemodule UpdateSecurityResponse = Awso_kafka.Values.UpdateSecurityResponse

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

Sourcemodule UpdateSecurityRequest = Awso_kafka.Values.UpdateSecurityRequest

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

Source

module UpdateReplicationInfoResponse =
  Awso_kafka.Values.UpdateReplicationInfoResponse

Updates replication info of a replicator.

Source

module UpdateReplicationInfoRequest =
  Awso_kafka.Values.UpdateReplicationInfoRequest

Update information relating to replication between a given source and target Kafka cluster.

Sourcemodule UpdateRebalancingResponse = Awso_kafka.Values.UpdateRebalancingResponse

Use this resource to update the intelligent rebalancing status of an Amazon MSK Provisioned cluster with Express brokers.

Sourcemodule UpdateRebalancingRequest = Awso_kafka.Values.UpdateRebalancingRequest

Use this resource to update the intelligent rebalancing status of an Amazon MSK Provisioned cluster with Express brokers.

Sourcemodule UpdateMonitoringResponse = Awso_kafka.Values.UpdateMonitoringResponse

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.

Sourcemodule UpdateMonitoringRequest = Awso_kafka.Values.UpdateMonitoringRequest

Request body for UpdateMonitoring.

Source

module UpdateConnectivityResponse =
  Awso_kafka.Values.UpdateConnectivityResponse

Updates the cluster's connectivity configuration.

Sourcemodule UpdateConnectivityRequest = Awso_kafka.Values.UpdateConnectivityRequest

Request body for UpdateConnectivity.

Source

module UpdateConfigurationResponse =
  Awso_kafka.Values.UpdateConfigurationResponse

Updates an MSK configuration.

Source

module UpdateConfigurationRequest =
  Awso_kafka.Values.UpdateConfigurationRequest

Updates an MSK configuration.

Source

module UpdateClusterKafkaVersionResponse =
  Awso_kafka.Values.UpdateClusterKafkaVersionResponse

Updates the Apache Kafka version for the cluster.

Source

module UpdateClusterKafkaVersionRequest =
  Awso_kafka.Values.UpdateClusterKafkaVersionRequest

Updates the Apache Kafka version for the cluster.

Source

module UpdateClusterConfigurationResponse =
  Awso_kafka.Values.UpdateClusterConfigurationResponse

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

Source

module UpdateClusterConfigurationRequest =
  Awso_kafka.Values.UpdateClusterConfigurationRequest

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

Sourcemodule UpdateBrokerTypeResponse = Awso_kafka.Values.UpdateBrokerTypeResponse

Updates EC2 instance type.

Sourcemodule UpdateBrokerTypeRequest = Awso_kafka.Values.UpdateBrokerTypeRequest

Updates EC2 instance type.

Source

module UpdateBrokerStorageResponse =
  Awso_kafka.Values.UpdateBrokerStorageResponse

Updates the EBS storage associated with MSK brokers.

Source

module UpdateBrokerStorageRequest =
  Awso_kafka.Values.UpdateBrokerStorageRequest

Updates the EBS storage associated with MSK brokers.

Sourcemodule UpdateBrokerCountResponse = Awso_kafka.Values.UpdateBrokerCountResponse

Updates the number of broker nodes in the cluster.

Sourcemodule UpdateBrokerCountRequest = Awso_kafka.Values.UpdateBrokerCountRequest

Updates the number of broker nodes in the cluster.

Sourcemodule UntagResourceRequest = Awso_kafka.Values.UntagResourceRequest

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

Sourcemodule TagResourceRequest = Awso_kafka.Values.TagResourceRequest

Adds tags to the specified MSK resource.

Source

module RejectClientVpcConnectionResponse =
  Awso_kafka.Values.RejectClientVpcConnectionResponse

Returns empty response.

Source

module RejectClientVpcConnectionRequest =
  Awso_kafka.Values.RejectClientVpcConnectionRequest

Returns empty response.

Sourcemodule RebootBrokerResponse = Awso_kafka.Values.RebootBrokerResponse

Reboots brokers.

Sourcemodule RebootBrokerRequest = Awso_kafka.Values.RebootBrokerRequest

Reboots a node.

Sourcemodule PutClusterPolicyResponse = Awso_kafka.Values.PutClusterPolicyResponse

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

Sourcemodule PutClusterPolicyRequest = Awso_kafka.Values.PutClusterPolicyRequest

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

Source

module ListVpcConnectionsResponse =
  Awso_kafka.Values.ListVpcConnectionsResponse

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

Sourcemodule ListVpcConnectionsRequest = Awso_kafka.Values.ListVpcConnectionsRequest

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

Sourcemodule ListTopicsResponse = Awso_kafka.Values.ListTopicsResponse

List topics in a MSK cluster.

Sourcemodule ListTopicsRequest = Awso_kafka.Values.ListTopicsRequest

List topics in a MSK cluster.

Source

module ListTagsForResourceResponse =
  Awso_kafka.Values.ListTagsForResourceResponse

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

Source

module ListTagsForResourceRequest =
  Awso_kafka.Values.ListTagsForResourceRequest

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

Sourcemodule ListScramSecretsResponse = Awso_kafka.Values.ListScramSecretsResponse

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

Sourcemodule ListScramSecretsRequest = Awso_kafka.Values.ListScramSecretsRequest

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

Sourcemodule ListReplicatorsResponse = Awso_kafka.Values.ListReplicatorsResponse

Lists the replicators.

Sourcemodule ListReplicatorsRequest = Awso_kafka.Values.ListReplicatorsRequest

Lists the replicators.

Sourcemodule ListNodesResponse = Awso_kafka.Values.ListNodesResponse

Returns a list of the broker nodes in the cluster.

Sourcemodule ListNodesRequest = Awso_kafka.Values.ListNodesRequest

Returns a list of the broker nodes in the cluster.

Sourcemodule ListKafkaVersionsResponse = Awso_kafka.Values.ListKafkaVersionsResponse

Returns a list of Apache Kafka versions.

Sourcemodule ListKafkaVersionsRequest = Awso_kafka.Values.ListKafkaVersionsRequest

Returns a list of Apache Kafka versions.

Source

module ListConfigurationsResponse =
  Awso_kafka.Values.ListConfigurationsResponse

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

Sourcemodule ListConfigurationsRequest = Awso_kafka.Values.ListConfigurationsRequest

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

Source

module ListConfigurationRevisionsResponse =
  Awso_kafka.Values.ListConfigurationRevisionsResponse

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

Source

module ListConfigurationRevisionsRequest =
  Awso_kafka.Values.ListConfigurationRevisionsRequest

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

Sourcemodule ListClustersV2Response = Awso_kafka.Values.ListClustersV2Response

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

Sourcemodule ListClustersV2Request = Awso_kafka.Values.ListClustersV2Request

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

Sourcemodule ListClustersResponse = Awso_kafka.Values.ListClustersResponse

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

Sourcemodule ListClustersRequest = Awso_kafka.Values.ListClustersRequest

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

Source

module ListClusterOperationsV2Response =
  Awso_kafka.Values.ListClusterOperationsV2Response

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

Source

module ListClusterOperationsV2Request =
  Awso_kafka.Values.ListClusterOperationsV2Request

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

Source

module ListClusterOperationsResponse =
  Awso_kafka.Values.ListClusterOperationsResponse

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

Source

module ListClusterOperationsRequest =
  Awso_kafka.Values.ListClusterOperationsRequest

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

Source

module ListClientVpcConnectionsResponse =
  Awso_kafka.Values.ListClientVpcConnectionsResponse

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

Source

module ListClientVpcConnectionsRequest =
  Awso_kafka.Values.ListClientVpcConnectionsRequest

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

Source

module GetCompatibleKafkaVersionsResponse =
  Awso_kafka.Values.GetCompatibleKafkaVersionsResponse

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

Source

module GetCompatibleKafkaVersionsRequest =
  Awso_kafka.Values.GetCompatibleKafkaVersionsRequest

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

Sourcemodule GetClusterPolicyResponse = Awso_kafka.Values.GetClusterPolicyResponse

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

Sourcemodule GetClusterPolicyRequest = Awso_kafka.Values.GetClusterPolicyRequest

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

Source

module GetBootstrapBrokersResponse =
  Awso_kafka.Values.GetBootstrapBrokersResponse

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.

Source

module GetBootstrapBrokersRequest =
  Awso_kafka.Values.GetBootstrapBrokersRequest

Sourcemodule Error = Awso_kafka.Values.Error

Returns information about an error.

Source

module DescribeVpcConnectionResponse =
  Awso_kafka.Values.DescribeVpcConnectionResponse

Returns a description of this MSK VPC connection.

Source

module DescribeVpcConnectionRequest =
  Awso_kafka.Values.DescribeVpcConnectionRequest

Returns a description of this MSK VPC connection.

Sourcemodule DescribeTopicResponse = Awso_kafka.Values.DescribeTopicResponse

Returns topic details of this topic on a MSK cluster.

Sourcemodule DescribeTopicRequest = Awso_kafka.Values.DescribeTopicRequest

Returns topic details of this topic on a MSK cluster.

Source

module DescribeTopicPartitionsResponse =
  Awso_kafka.Values.DescribeTopicPartitionsResponse

Returns partition details of this topic on a MSK cluster.

Source

module DescribeTopicPartitionsRequest =
  Awso_kafka.Values.DescribeTopicPartitionsRequest

Returns partition details of this topic on a MSK cluster.

Source

module DescribeReplicatorResponse =
  Awso_kafka.Values.DescribeReplicatorResponse

Describes a replicator.

Sourcemodule DescribeReplicatorRequest = Awso_kafka.Values.DescribeReplicatorRequest

Describes a replicator.

Source

module DescribeConfigurationRevisionResponse =
  Awso_kafka.Values.DescribeConfigurationRevisionResponse

Returns a description of this revision of the configuration.

Source

module DescribeConfigurationRevisionRequest =
  Awso_kafka.Values.DescribeConfigurationRevisionRequest

Returns a description of this revision of the configuration.

Source

module DescribeConfigurationResponse =
  Awso_kafka.Values.DescribeConfigurationResponse

Returns a description of this MSK configuration.

Source

module DescribeConfigurationRequest =
  Awso_kafka.Values.DescribeConfigurationRequest

Returns a description of this MSK configuration.

Sourcemodule DescribeClusterV2Response = Awso_kafka.Values.DescribeClusterV2Response

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

Sourcemodule DescribeClusterV2Request = Awso_kafka.Values.DescribeClusterV2Request

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

Sourcemodule DescribeClusterResponse = Awso_kafka.Values.DescribeClusterResponse

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

Sourcemodule DescribeClusterRequest = Awso_kafka.Values.DescribeClusterRequest

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

Source

module DescribeClusterOperationV2Response =
  Awso_kafka.Values.DescribeClusterOperationV2Response

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

Source

module DescribeClusterOperationV2Request =
  Awso_kafka.Values.DescribeClusterOperationV2Request

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

Source

module DescribeClusterOperationResponse =
  Awso_kafka.Values.DescribeClusterOperationResponse

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

Source

module DescribeClusterOperationRequest =
  Awso_kafka.Values.DescribeClusterOperationRequest

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

Source

module DeleteVpcConnectionResponse =
  Awso_kafka.Values.DeleteVpcConnectionResponse

Deletes a MSK VPC connection.

Source

module DeleteVpcConnectionRequest =
  Awso_kafka.Values.DeleteVpcConnectionRequest

Deletes a MSK VPC connection.

Sourcemodule DeleteTopicResponse = Awso_kafka.Values.DeleteTopicResponse

Deletes a topic in the specified MSK cluster.

Sourcemodule DeleteTopicRequest = Awso_kafka.Values.DeleteTopicRequest

Deletes a topic in the specified MSK cluster.

Sourcemodule DeleteReplicatorResponse = Awso_kafka.Values.DeleteReplicatorResponse

Deletes a replicator.

Sourcemodule DeleteReplicatorRequest = Awso_kafka.Values.DeleteReplicatorRequest

Deletes a replicator.

Source

module DeleteConfigurationResponse =
  Awso_kafka.Values.DeleteConfigurationResponse

Deletes an MSK Configuration.

Source

module DeleteConfigurationRequest =
  Awso_kafka.Values.DeleteConfigurationRequest

Deletes an MSK Configuration.

Sourcemodule DeleteClusterResponse = Awso_kafka.Values.DeleteClusterResponse

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

Sourcemodule DeleteClusterRequest = Awso_kafka.Values.DeleteClusterRequest

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

Source

module DeleteClusterPolicyResponse =
  Awso_kafka.Values.DeleteClusterPolicyResponse

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

Source

module DeleteClusterPolicyRequest =
  Awso_kafka.Values.DeleteClusterPolicyRequest

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

Source

module CreateVpcConnectionResponse =
  Awso_kafka.Values.CreateVpcConnectionResponse

Creates a new MSK VPC connection.

Source

module CreateVpcConnectionRequest =
  Awso_kafka.Values.CreateVpcConnectionRequest

Creates a new MSK VPC connection.

Sourcemodule CreateTopicResponse = Awso_kafka.Values.CreateTopicResponse

Creates a topic in the specified MSK cluster.

Sourcemodule CreateTopicRequest = Awso_kafka.Values.CreateTopicRequest

Creates a topic in the specified MSK cluster.

Sourcemodule CreateReplicatorResponse = Awso_kafka.Values.CreateReplicatorResponse

Creates the replicator.

Sourcemodule CreateReplicatorRequest = Awso_kafka.Values.CreateReplicatorRequest

Creates a replicator using the specified configuration.

Source

module CreateConfigurationResponse =
  Awso_kafka.Values.CreateConfigurationResponse

Creates a new MSK configuration.

Source

module CreateConfigurationRequest =
  Awso_kafka.Values.CreateConfigurationRequest

Creates a new MSK configuration.

Sourcemodule CreateClusterV2Response = Awso_kafka.Values.CreateClusterV2Response

Creates a new MSK cluster.

Sourcemodule CreateClusterV2Request = Awso_kafka.Values.CreateClusterV2Request

Creates a new MSK cluster.

Sourcemodule CreateClusterResponse = Awso_kafka.Values.CreateClusterResponse

Creates a new MSK cluster.

Sourcemodule CreateClusterRequest = Awso_kafka.Values.CreateClusterRequest

Creates a new MSK cluster.

Source

module BatchDisassociateScramSecretResponse =
  Awso_kafka.Values.BatchDisassociateScramSecretResponse

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

Source

module BatchDisassociateScramSecretRequest =
  Awso_kafka.Values.BatchDisassociateScramSecretRequest

Disassociates sasl scram secrets to cluster.

Source

module BatchAssociateScramSecretResponse =
  Awso_kafka.Values.BatchAssociateScramSecretResponse

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

Source

module BatchAssociateScramSecretRequest =
  Awso_kafka.Values.BatchAssociateScramSecretRequest

Associates sasl scram secrets to cluster.