Module Awso_kafka.ValuesSource

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
Sourceval structure_to_value_aux : ('a * 'b option) list -> f:(('a * 'b) list -> 'c) -> [> `Structure of 'c ]
Sourceval structure_to_value : ('a * 'b option) list -> [> `Structure of ('a * 'b) list ]
Sourceval structure_to_wrapped_value : wrapper:'a -> response:'a -> ('b * 'c option) list -> [> `Structure of ('a * [> `Structure of ('b * 'c) list ]) list ]
Sourcemodule VpcConnectivityIam : sig ... end

Details for IAM access control for VPC connectivity.

Sourcemodule VpcConnectivityScram : sig ... end

Details for SASL/SCRAM client authentication for VPC connectivity.

Sourcemodule VpcConnectivitySasl : sig ... end

Details for SASL client authentication for VPC connectivity.

Sourcemodule VpcConnectivityTls : sig ... end

Details for TLS client authentication for VPC connectivity.

Includes all client authentication information for VPC connectivity.

Sourcemodule ProvisionedThroughput : sig ... end

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

Sourcemodule NetworkType : sig ... end
Sourcemodule PublicAccess : sig ... end

Public access control for brokers.

Sourcemodule VpcConnectivity : sig ... end

VPC connectivity access control for brokers.

Sourcemodule EBSStorageInfo : sig ... end

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

Sourcemodule Iam : sig ... end

Details for IAM access control.

Sourcemodule Scram : sig ... end

Details for SASL/SCRAM client authentication.

Sourcemodule ClientBroker : sig ... end
Sourcemodule CloudWatchLogs : sig ... end
Sourcemodule Firehose : sig ... end
Sourcemodule S3 : sig ... end
Sourcemodule JmxExporterInfo : sig ... end

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

Sourcemodule NodeExporterInfo : sig ... end

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

Sourcemodule JmxExporter : sig ... end

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

Sourcemodule NodeExporter : sig ... end

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

Sourcemodule AmazonMskCluster : sig ... end

Details of an Amazon MSK Cluster.

Sourcemodule ApacheKafkaCluster : sig ... end

Details of an Apache Kafka Cluster.

Sourcemodule BrokerAZDistribution : sig ... end
Sourcemodule ConnectivityInfo : sig ... end

Information about the broker access configuration.

Sourcemodule StorageInfo : sig ... end

Contains information about storage volumes attached to MSK broker nodes.

Sourcemodule Sasl : sig ... end

Details for client authentication using SASL.

Sourcemodule Tls : sig ... end

Details for client authentication using TLS.

Sourcemodule Unauthenticated : sig ... end
Sourcemodule EncryptionAtRest : sig ... end

The data-volume encryption details.

Sourcemodule EncryptionInTransit : sig ... end

The settings for encrypting data in transit.

Sourcemodule BrokerLogs : sig ... end
Sourcemodule PrometheusInfo : sig ... end

Prometheus settings.

Sourcemodule RebalancingStatus : sig ... end
Sourcemodule ServerlessSasl : sig ... end

Details for client authentication using SASL.

Sourcemodule VpcConfig : sig ... end

The configuration of the Amazon VPCs for the cluster.

Sourcemodule Prometheus : sig ... end

Prometheus settings.

Sourcemodule BrokerEBSVolumeInfo : sig ... end

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 : sig ... end
Sourcemodule ClusterOperationStepInfo : sig ... end

State information about the operation step.

Sourcemodule KafkaClusterSummary : sig ... end

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

Sourcemodule ReplicationInfoSummary : sig ... end

Summarized information of replication between clusters.

Sourcemodule BrokerSoftwareInfo : sig ... end

Information about the current software installed on the cluster.

Sourcemodule BrokerNodeGroupInfo : sig ... end

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

Sourcemodule ClientAuthentication : sig ... end

Includes all client authentication information.

Sourcemodule CustomerActionStatus : sig ... end
Sourcemodule EncryptionInfo : sig ... end

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 : sig ... end
Sourcemodule LoggingInfo : sig ... end
Sourcemodule OpenMonitoringInfo : sig ... end

JMX and Node monitoring for the MSK cluster.

Sourcemodule Rebalancing : sig ... end

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 : sig ... end

Includes all client authentication information.

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

Sourcemodule BrokerCountUpdateInfo : sig ... end

Information regarding UpdateBrokerCount.

Sourcemodule ConfigurationInfo : sig ... end

Specifies the configuration to use for the brokers.

Sourcemodule OpenMonitoring : sig ... end

JMX and Node monitoring for the MSK cluster.

Sourcemodule ZookeeperAccess : sig ... end

Access control settings for zookeeper

Sourcemodule UserIdentity : sig ... end

Description of the requester that calls the API operation.

Sourcemodule ClusterOperationStep : sig ... end

Step taken during a cluster operation.

Details for SASL/SCRAM client authentication.

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

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

Sourcemodule ReplicatorCloudWatchLogs : sig ... end

Details about delivering logs to CloudWatch Logs.

Sourcemodule ReplicatorFirehose : sig ... end

Details about delivering logs to Firehose.

Sourcemodule ReplicatorS3 : sig ... end

Details about delivering logs to S3.

Sourcemodule VpcConnectionState : sig ... end
Sourcemodule ReplicatorState : sig ... end
Sourcemodule BrokerNodeInfo : sig ... end

BrokerNodeInfo

Sourcemodule ControllerNodeInfo : sig ... end

Controller node information.

Sourcemodule NodeType : sig ... end
Sourcemodule ZookeeperNodeInfo : sig ... end

Zookeeper node information.

Sourcemodule KafkaVersionStatus : sig ... end
Sourcemodule ConfigurationRevision : sig ... end

Describes a configuration revision.

Sourcemodule ConfigurationState : sig ... end
Sourcemodule ClusterState : sig ... end
Sourcemodule ClusterType : sig ... end
Sourcemodule Provisioned : sig ... end

Provisioned cluster.

Sourcemodule Serverless : sig ... end

Serverless cluster.

Sourcemodule StateInfo : sig ... end
Sourcemodule ErrorInfo : sig ... end

Returns information about an error state of the cluster.

Sourcemodule MutableClusterInfo : sig ... end

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

Sourcemodule VpcConnectionInfo : sig ... end

Description of the VPC connection.

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

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

Details of encryption in transit to the Apache Kafka cluster.

Sourcemodule ConsumerGroupReplication : sig ... end

Details about consumer group replication.

Sourcemodule TargetCompressionType : sig ... end
Sourcemodule TopicReplication : sig ... end

Details about topic replication.

Description of the VPC connection.

Sourcemodule ReplicatorLogDelivery : sig ... end

Configuration for replicator log delivery.

Sourcemodule VpcConnection : sig ... end

The VPC connection object.

Sourcemodule TopicInfo : sig ... end

Includes identification info about the topic.

Sourcemodule ReplicatorSummary : sig ... end

Information about a replicator.

Sourcemodule NodeInfo : sig ... end

The node information object.

Sourcemodule KafkaVersion : sig ... end
Sourcemodule Configuration : sig ... end

Represents an MSK Configuration.

Sourcemodule Cluster : sig ... end

Returns information about a cluster.

Sourcemodule ClusterInfo : sig ... end

Returns information about a cluster.

Sourcemodule ClusterOperationV2Summary : sig ... end

Returns information about a cluster operation.

Sourcemodule ClusterOperationInfo : sig ... end

Returns information about a cluster operation.

Sourcemodule ClientVpcConnection : sig ... end

The client VPC connection object.

Sourcemodule CompatibleKafkaVersion : sig ... end

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

Sourcemodule TopicPartitionInfo : sig ... end

Contains information about a topic partition.

Sourcemodule KafkaClusterDescription : sig ... end

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

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

Returns information about a provisioned cluster operation.

Returns information about a serverless cluster operation.

Sourcemodule KafkaCluster : sig ... end

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

Sourcemodule ReplicationInfo : sig ... end

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

Sourcemodule UnprocessedScramSecret : sig ... end

Error info for scram secret associate/disassociate failure.

Sourcemodule BadRequestException : sig ... end

Returns information about an error.

Returns information about an error.

Sourcemodule ControllerMovedException : sig ... end

Returns information about an error.

Sourcemodule ForbiddenException : sig ... end

Returns information about an error.

Returns information about an error.

Returns information about an error.

Sourcemodule KafkaRequestException : sig ... end

Returns information about an error.

Sourcemodule KafkaTimeoutException : sig ... end

Returns information about an error.

Sourcemodule NotControllerException : sig ... end

Returns information about an error.

Sourcemodule NotFoundException : sig ... end

Returns information about an error.

Returns information about an error.

Returns information about an error.

Sourcemodule TopicState : sig ... end
Sourcemodule UnauthorizedException : sig ... end

Returns information about an error.

Returns information about an error.

Sourcemodule TooManyRequestsException : sig ... end

Returns information about an error.

Details about consumer group replication.

Sourcemodule LogDelivery : sig ... end

Configuration for log delivery to customer destinations.

Sourcemodule TopicReplicationUpdate : sig ... end

Details for updating the topic replication of a replicator.

Sourcemodule MaxResults : sig ... end
Sourcemodule ConflictException : sig ... end

Returns information about an error.

Sourcemodule ReplicationStateInfo : sig ... end

Details about the state of a replicator

Sourcemodule ClusterOperationV2 : sig ... end

Returns information about a cluster operation.

Sourcemodule TopicExistsException : sig ... end

Returns information about an error.

Sourcemodule ProvisionedRequest : sig ... end

Provisioned cluster request.

Sourcemodule ServerlessRequest : sig ... end

Serverless cluster request.

Sourcemodule UpdateTopicResponse : sig ... end

Updates the configuration of the specified topic.

Sourcemodule UpdateTopicRequest : sig ... end

Updates the configuration of the specified topic.

Sourcemodule UpdateStorageResponse : sig ... end

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

Sourcemodule UpdateStorageRequest : sig ... end

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

Sourcemodule UpdateSecurityResponse : sig ... end

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

Sourcemodule UpdateSecurityRequest : sig ... end

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

Updates replication info of a replicator.

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

Sourcemodule UpdateRebalancingResponse : sig ... end

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

Sourcemodule UpdateRebalancingRequest : sig ... end

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

Sourcemodule UpdateMonitoringResponse : sig ... end

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 : sig ... end

Request body for UpdateMonitoring.

Updates the cluster's connectivity configuration.

Sourcemodule UpdateConnectivityRequest : sig ... end

Request body for UpdateConnectivity.

Updates an MSK configuration.

Updates an MSK configuration.

Updates the Apache Kafka version for the cluster.

Updates the Apache Kafka version for the cluster.

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

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

Sourcemodule UpdateBrokerTypeResponse : sig ... end

Updates EC2 instance type.

Sourcemodule UpdateBrokerTypeRequest : sig ... end

Updates EC2 instance type.

Updates the EBS storage associated with MSK brokers.

Updates the EBS storage associated with MSK brokers.

Sourcemodule UpdateBrokerCountResponse : sig ... end

Updates the number of broker nodes in the cluster.

Sourcemodule UpdateBrokerCountRequest : sig ... end

Updates the number of broker nodes in the cluster.

Sourcemodule UntagResourceRequest : sig ... end

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

Sourcemodule TagResourceRequest : sig ... end

Adds tags to the specified MSK resource.

Returns empty response.

Returns empty response.

Sourcemodule RebootBrokerResponse : sig ... end

Reboots brokers.

Sourcemodule RebootBrokerRequest : sig ... end

Reboots a node.

Sourcemodule PutClusterPolicyResponse : sig ... end

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

Sourcemodule PutClusterPolicyRequest : sig ... end

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

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

Sourcemodule ListVpcConnectionsRequest : sig ... end

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

Sourcemodule ListTopicsResponse : sig ... end

List topics in a MSK cluster.

Sourcemodule ListTopicsRequest : sig ... end

List topics in a MSK cluster.

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

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

Sourcemodule ListScramSecretsResponse : sig ... end

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

Sourcemodule ListScramSecretsRequest : sig ... end

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

Sourcemodule ListReplicatorsResponse : sig ... end

Lists the replicators.

Sourcemodule ListReplicatorsRequest : sig ... end

Lists the replicators.

Sourcemodule ListNodesResponse : sig ... end

Returns a list of the broker nodes in the cluster.

Sourcemodule ListNodesRequest : sig ... end

Returns a list of the broker nodes in the cluster.

Sourcemodule ListKafkaVersionsResponse : sig ... end

Returns a list of Apache Kafka versions.

Sourcemodule ListKafkaVersionsRequest : sig ... end

Returns a list of Apache Kafka versions.

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

Sourcemodule ListConfigurationsRequest : sig ... end

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

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

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

Sourcemodule ListClustersV2Response : sig ... end

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

Sourcemodule ListClustersV2Request : sig ... end

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

Sourcemodule ListClustersResponse : sig ... end

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

Sourcemodule ListClustersRequest : sig ... end

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

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

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

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

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

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

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

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

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

Sourcemodule GetClusterPolicyResponse : sig ... end

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

Sourcemodule GetClusterPolicyRequest : sig ... end

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

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.

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.

Sourcemodule Error : sig ... end

Returns information about an error.

Returns a description of this MSK VPC connection.

Returns a description of this MSK VPC connection.

Sourcemodule DescribeTopicResponse : sig ... end

Returns topic details of this topic on a MSK cluster.

Sourcemodule DescribeTopicRequest : sig ... end

Returns topic details of this topic on a MSK cluster.

Returns partition details of this topic on a MSK cluster.

Returns partition details of this topic on a MSK cluster.

Describes a replicator.

Sourcemodule DescribeReplicatorRequest : sig ... end

Describes a replicator.

Returns a description of this revision of the configuration.

Returns a description of this revision of the configuration.

Returns a description of this MSK configuration.

Returns a description of this MSK configuration.

Sourcemodule DescribeClusterV2Response : sig ... end

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

Sourcemodule DescribeClusterV2Request : sig ... end

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

Sourcemodule DescribeClusterResponse : sig ... end

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

Sourcemodule DescribeClusterRequest : sig ... end

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

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

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

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

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

Deletes a MSK VPC connection.

Deletes a MSK VPC connection.

Sourcemodule DeleteTopicResponse : sig ... end

Deletes a topic in the specified MSK cluster.

Sourcemodule DeleteTopicRequest : sig ... end

Deletes a topic in the specified MSK cluster.

Sourcemodule DeleteReplicatorResponse : sig ... end

Deletes a replicator.

Sourcemodule DeleteReplicatorRequest : sig ... end

Deletes a replicator.

Deletes an MSK Configuration.

Deletes an MSK Configuration.

Sourcemodule DeleteClusterResponse : sig ... end

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

Sourcemodule DeleteClusterRequest : sig ... end

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

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

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

Creates a new MSK VPC connection.

Creates a new MSK VPC connection.

Sourcemodule CreateTopicResponse : sig ... end

Creates a topic in the specified MSK cluster.

Sourcemodule CreateTopicRequest : sig ... end

Creates a topic in the specified MSK cluster.

Sourcemodule CreateReplicatorResponse : sig ... end

Creates the replicator.

Sourcemodule CreateReplicatorRequest : sig ... end

Creates a replicator using the specified configuration.

Creates a new MSK configuration.

Creates a new MSK configuration.

Sourcemodule CreateClusterV2Response : sig ... end

Creates a new MSK cluster.

Sourcemodule CreateClusterV2Request : sig ... end

Creates a new MSK cluster.

Sourcemodule CreateClusterResponse : sig ... end

Creates a new MSK cluster.

Sourcemodule CreateClusterRequest : sig ... end

Creates a new MSK cluster.

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

Disassociates sasl scram secrets to cluster.

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

Associates sasl scram secrets to cluster.