Package-level declarations
Types
Details of an Amazon MSK Cluster.
Details of an Apache Kafka Cluster.
Returns information about an error.
Associates sasl scram secrets to cluster.
Disassociates sasl scram secrets to cluster.
The distribution of broker nodes across Availability Zones. This is an optional parameter. If you don't specify it, Amazon MSK gives it the value DEFAULT. You can also explicitly set this parameter to the value DEFAULT. No other values are currently allowed.
Information regarding UpdateBrokerCount.
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.
Describes the setup to be used for Apache Kafka broker nodes in the cluster.
BrokerNodeInfo
Information about the current software installed on the cluster.
The type of destination configured for the channel.
Summary information about a channel returned by ListChannels.
Configuration for the destinations to which the channel publishes operational logs.
Additional context for the current channel state, populated when the channel is in FAILED.
The lifecycle state of a channel.
Includes all client authentication information.
Client-broker encryption in transit setting.
The client VPC connection object.
Returns information about an error.
Returns information about a cluster.
Returns information about a cluster operation.
Step taken during a cluster operation.
State information about the operation step.
Returns information about a cluster operation.
Returns information about a provisioned cluster operation.
Returns information about a serverless cluster operation.
Returns information about a cluster operation.
The state of the Apache Kafka cluster.
The type of cluster.
Contains source Apache Kafka versions and compatible target Apache Kafka versions.
Represents an MSK Configuration.
Specifies the configuration to use for the brokers.
Describes a configuration revision.
The state of a configuration.
Returns information about an error.
Information about the broker access configuration.
The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.
Details about consumer group replication.
Details about consumer group replication.
Returns information about an error.
Controller node information.
Creates a Channel that streams records from an Amazon MSK Express cluster topic to Amazon S3 or Apache Iceberg.
Returns the channel ARN and the cluster-operation ARN that tracks the asynchronous create.
Creates a replicator using the specified configuration.
A type of an action required from the customer.
Configuration of the Amazon S3 bucket where records that fail to deliver are stored.
Returns the channel ARN and the cluster-operation ARN that tracks the asynchronous delete.
Contains the current configuration and state of a channel.
Configuration of an Apache Iceberg destination table.
Contains information about the EBS storage volumes attached to Apache Kafka broker nodes.
The data-volume encryption details.
The AWS KMS encryption configuration applied to data at rest.
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.
The settings for encrypting data in transit.
Specifies which metrics are gathered for the MSK cluster. This property has the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each of these levels of monitoring, see Monitoring.
Returns information about an error.
Returns information about an error.
Compression codec for Iceberg table data files. Defaults to ZSTD.
Configuration of an Apache Iceberg destination for a channel.
Update payload for an Apache Iceberg destination.
Returns information about an error.
Indicates whether you want to turn on or turn off the JMX Exporter.
Indicates whether you want to turn on or turn off the JMX Exporter.
Information about Kafka Cluster to be used as source / target for replication.
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.
Information about Kafka Cluster used as source / target for replication.
Details of encryption in transit to the Apache Kafka cluster.
The type of encryption in transit to the Apache Kafka cluster.
Details for mTLS client authentication.
Details for SASL/SCRAM client authentication.
The SASL/SCRAM authentication mechanism.
Summarized information about Kafka Cluster used as source / target for replication.
Base class for all service related exceptions thrown by the Kafka client
Returns information about an error.
Returns information about an error.
Returns the list of channels in the cluster.
Configuration for log delivery to customer destinations.
Information about cluster attributes that can be updated via update APIs.
The network type of the cluster, which is IPv4 or DUAL. The DUAL network type uses both IPv4 and IPv6 addresses for your cluster and its resources.
Indicates whether you want to turn on or turn off the Node Exporter.
Indicates whether you want to turn on or turn off the Node Exporter.
Returns information about an error.
Returns information about an error.
JMX and Node monitoring for the MSK cluster.
JMX and Node monitoring for the MSK cluster.
A source column used by an Apache Iceberg destination table's partition specification.
Partition specification for an Apache Iceberg destination table.
The partitioning strategy used to partition records in the destination Apache Iceberg table.
Prometheus settings.
Prometheus settings.
Provisioned cluster.
Provisioned cluster request.
Contains information about provisioned throughput for EBS storage volumes attached to kafka broker nodes.
Public access control for brokers.
Returns information about an error.
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.
Intelligent rebalancing status. The default intelligent rebalancing status is ACTIVE for all new Express-based clusters.
Reboots a node.
Configuration that controls how Apache Kafka record values are deserialized for the destination.
Schema configuration that controls how Apache Kafka record values are validated.
Specifies configuration for replication between a source and target Kafka cluster.
Specifies configuration for replication between a source and target Kafka cluster (sourceKafkaClusterAlias -> targetKafkaClusterAlias)
Summarized information of replication between clusters.
Configuration for specifying the position in the topics to start replicating from.
The type of replication starting position.
Details about the state of a replicator
Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.
The type of replicated topic name.
Details about delivering logs to CloudWatch Logs.
Details about delivering logs to Firehose.
Configuration for replicator log delivery.
Details about delivering logs to S3.
The state of a replicator.
Information about a replicator.
The compression codec applied to delivered Amazon S3 objects.
Configuration of an Amazon S3 destination for a channel.
Update payload for an Amazon S3 destination.
The Amazon S3 storage class applied to delivered objects.
Configuration controlling whether the Apache Iceberg destination table's schema is evolved as incoming records change.
Serverless cluster.
Includes all client authentication information.
Describes the cluster's connectivity information, such as its network type, which is IPv4 or DUAL.
Serverless cluster request.
Details for client authentication using SASL.
Returns information about an error.
Contains information about storage volumes attached to MSK broker nodes.
Controls storage mode for various supported storage tiers.
Configuration controlling whether MSK creates the destination Apache Iceberg table if it does not already exist.
The type of compression to use producing records to the target cluster.
Returns information about an error.
Configuration of an Apache Kafka topic that feeds a channel.
Returns information about an error.
Contains information about a topic partition.
Details about topic replication.
Details for updating the topic replication of a replicator.
The state of a topic request.
Returns information about an error.
Returns information about an error.
Error info for scram secret associate/disassociate failure.
Updates an existing channel's destination configuration. You must update the same destination type the channel was created with; the destination type cannot be changed.
Returns the channel ARN and the cluster-operation ARN that tracks the asynchronous update.
Request body for UpdateConnectivity.
Request body for UpdateMonitoring.
Update information relating to replication between a given source and target Kafka cluster.
Request object for UpdateStorage api. Its used to update the storage attributes for the cluster.
Description of the requester that calls the API operation.
The identity type of the requester that calls the API operation.
The deserialization format applied to Apache Kafka record values.
The VPC connection object.
Description of the VPC connection.
Description of the VPC connection.
The state of a VPC connection.
VPC connectivity access control for brokers.
Includes all client authentication information for VPC connectivity.
Details for IAM access control for VPC connectivity.
Details for SASL client authentication for VPC connectivity.
Details for SASL/SCRAM client authentication for VPC connectivity.
Details for TLS client authentication for VPC connectivity.
Access control settings for zookeeper
Zookeeper node information.