# Packages
Package kafkaiface provides an interface to enable mocking the Managed Streaming for Kafka service client for testing your code.
# Functions
BrokerAZDistribution_Values returns all elements of the BrokerAZDistribution enum.
ClientBroker_Values returns all elements of the ClientBroker enum.
ClusterState_Values returns all elements of the ClusterState enum.
ClusterType_Values returns all elements of the ClusterType enum.
ConfigurationState_Values returns all elements of the ConfigurationState enum.
CustomerActionStatus_Values returns all elements of the CustomerActionStatus enum.
EnhancedMonitoring_Values returns all elements of the EnhancedMonitoring enum.
KafkaVersionStatus_Values returns all elements of the KafkaVersionStatus enum.
New creates a new instance of the Kafka client with a session.
NodeType_Values returns all elements of the NodeType enum.
ReplicationStartingPositionType_Values returns all elements of the ReplicationStartingPositionType enum.
ReplicatorState_Values returns all elements of the ReplicatorState enum.
StorageMode_Values returns all elements of the StorageMode enum.
TargetCompressionType_Values returns all elements of the TargetCompressionType enum.
UserIdentityType_Values returns all elements of the UserIdentityType enum.
VpcConnectionState_Values returns all elements of the VpcConnectionState enum.
# Constants
BrokerAZDistributionDefault is a BrokerAZDistribution enum value.
ClientBrokerPlaintext is a ClientBroker enum value.
ClientBrokerTls is a ClientBroker enum value.
ClientBrokerTlsPlaintext is a ClientBroker enum value.
ClusterStateActive is a ClusterState enum value.
ClusterStateCreating is a ClusterState enum value.
ClusterStateDeleting is a ClusterState enum value.
ClusterStateFailed is a ClusterState enum value.
ClusterStateHealing is a ClusterState enum value.
ClusterStateMaintenance is a ClusterState enum value.
ClusterStateRebootingBroker is a ClusterState enum value.
ClusterStateUpdating is a ClusterState enum value.
ClusterTypeProvisioned is a ClusterType enum value.
ClusterTypeServerless is a ClusterType enum value.
ConfigurationStateActive is a ConfigurationState enum value.
ConfigurationStateDeleteFailed is a ConfigurationState enum value.
ConfigurationStateDeleting is a ConfigurationState enum value.
CustomerActionStatusActionRecommended is a CustomerActionStatus enum value.
CustomerActionStatusCriticalActionRequired is a CustomerActionStatus enum value.
CustomerActionStatusNone is a CustomerActionStatus enum value.
ID to lookup a service endpoint with.
EnhancedMonitoringDefault is a EnhancedMonitoring enum value.
EnhancedMonitoringPerBroker is a EnhancedMonitoring enum value.
EnhancedMonitoringPerTopicPerBroker is a EnhancedMonitoring enum value.
EnhancedMonitoringPerTopicPerPartition is a EnhancedMonitoring enum value.
ErrCodeBadRequestException for service response error code "BadRequestException".
ErrCodeConflictException for service response error code "ConflictException".
ErrCodeForbiddenException for service response error code "ForbiddenException".
ErrCodeInternalServerErrorException for service response error code "InternalServerErrorException".
ErrCodeNotFoundException for service response error code "NotFoundException".
ErrCodeServiceUnavailableException for service response error code "ServiceUnavailableException".
ErrCodeTooManyRequestsException for service response error code "TooManyRequestsException".
ErrCodeUnauthorizedException for service response error code "UnauthorizedException".
KafkaVersionStatusActive is a KafkaVersionStatus enum value.
KafkaVersionStatusDeprecated is a KafkaVersionStatus enum value.
NodeTypeBroker is a NodeType enum value.
ReplicationStartingPositionTypeEarliest is a ReplicationStartingPositionType enum value.
ReplicationStartingPositionTypeLatest is a ReplicationStartingPositionType enum value.
ReplicatorStateCreating is a ReplicatorState enum value.
ReplicatorStateDeleting is a ReplicatorState enum value.
ReplicatorStateFailed is a ReplicatorState enum value.
ReplicatorStateRunning is a ReplicatorState enum value.
ReplicatorStateUpdating is a ReplicatorState enum value.
ServiceID is a unique identifier of a specific service.
Name of service.
StorageModeLocal is a StorageMode enum value.
StorageModeTiered is a StorageMode enum value.
TargetCompressionTypeGzip is a TargetCompressionType enum value.
TargetCompressionTypeLz4 is a TargetCompressionType enum value.
TargetCompressionTypeNone is a TargetCompressionType enum value.
TargetCompressionTypeSnappy is a TargetCompressionType enum value.
TargetCompressionTypeZstd is a TargetCompressionType enum value.
UserIdentityTypeAwsaccount is a UserIdentityType enum value.
UserIdentityTypeAwsservice is a UserIdentityType enum value.
VpcConnectionStateAvailable is a VpcConnectionState enum value.
VpcConnectionStateCreating is a VpcConnectionState enum value.
VpcConnectionStateDeactivating is a VpcConnectionState enum value.
VpcConnectionStateDeleting is a VpcConnectionState enum value.
VpcConnectionStateFailed is a VpcConnectionState enum value.
VpcConnectionStateInactive is a VpcConnectionState enum value.
VpcConnectionStateRejected is a VpcConnectionState enum value.
VpcConnectionStateRejecting is a VpcConnectionState enum value.
# Structs
Details of an Amazon MSK Cluster.
Returns information about an error.
Request body for BatchAssociateScramSecret.
Response body for BatchAssociateScramSecret.
Request body for BatchDisassociateScramSecret.
Response body for BatchDisassociateScramSecret.
Describes brokers being changed during a broker count update.
Specifies the EBS volume upgrade information.
The broker logs configuration for this MSK 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.
Includes all client authentication information.
The client VPC connection object.
Details of the CloudWatch Logs destination for broker logs.
Returns information about a cluster of either the provisioned or the serverless type.
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.
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.
Returns information about an error.
Information about the broker access configuration.
Details about consumer group replication.
Details about consumer group replication.
Controller node information.
Creates a cluster.
Returns information about the created cluster.
Creates a new Amazon MSK cluster of either the provisioned or the serverless type.
Returns information about the created cluster of either the provisioned or the serverless type.
Request body for CreateConfiguration.
Response body for CreateConfiguration.
Request body for replicator.
Returns information about the created replicator.
Request body for CreateVpcConnection.
Response body for CreateVpcConnection.
Returns information about the deleted cluster.
Request body for DeleteClusterPolicy.
Response body for DeleteClusterPolicy.
Request body for DeleteConfiguration.
Response body for DeleteConfiguration.
Returns information about the deleted replicator.
Request body for DeleteVpcConnection.
Response body for DeleteVpcConnection.
Information about a cluster operation.
Information about a cluster operation.
Returns information about a cluster.
Returns information about a cluster of either the provisioned or the serverless type.
Response body for DescribeConfiguration.
Response body for DescribeConfigurationRevision.
Response body for DescribeReplicator.
Response body for DescribeVpcConnection.
Contains information about the EBS storage volumes attached to Apache Kafka broker nodes.
The data-volume encryption details.
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.
Returns information about an error state of the cluster.
Firehose details for BrokerLogs.
Returns information about an error.
Returns a string containing one or more hostname:port pairs.
Request body for GetClusterPolicy.
Returns information about the specified cluster policy.
Response body for GetCompatibleKafkaVersions.
Returns information about an error.
Indicates whether you want to enable or disable the JMX Exporter.
Indicates whether you want to enable or disable the JMX Exporter.
Kafka provides the API operation methods for making requests to Managed Streaming for Kafka.
Information about Kafka Cluster to be used as source / target for replication.
Information about Kafka Cluster used as source / target for replication.
Summarized information about Kafka Cluster used as source / target for replication.
Information about a Apache Kafka version.
Request body for ListClientVpcConnections.
The response contains an array of client VPC connections and a next token if the response is truncated.
The response contains an array containing cluster operation information and a next token if the response is truncated.
The response contains an array containing cluster operation information and a next token if the response is truncated.
The response contains an array containing cluster information and a next token if the response is truncated.
The response contains an array containing cluster information and a next token if the response is truncated.
Information about revisions of an MSK configuration.
The response contains an array of Configuration and a next token if the response is truncated.
Response for ListKafkaVersions.
Information about nodes in the cluster.
The response contains an array containing replicator information and a NextToken if the response is truncated.
Information about scram secrets associated to the cluster.
Response of listing tags for a resource.
Request body for ListVpcConnections.
The response contains an array of MSK VPC connections and a next token if the response is truncated.
You can configure your MSK cluster to send broker logs to different destination types.
Information about cluster attributes that can be updated via update APIs.
Indicates whether you want to enable or disable the Node Exporter.
Indicates whether you want to enable or disable the Node Exporter.
The node information object.
Returns information about an error.
JMX and Node monitoring for the MSK cluster.
JMX and Node monitoring for the MSK cluster.
Prometheus settings for open monitoring.
Prometheus settings.
Describes the provisioned cluster.
Creates a provisioned cluster.
Contains information about provisioned throughput for EBS storage volumes attached to kafka broker nodes.
Broker public access control.
Request body for PutClusterPolicy.
Response body for PutClusterPolicy.
Request body for RebootBrokerNode action.
Response body for RebootBrokers action.
Request body for RejectClientVpcConnection.
Response body for RejectClientVpcConnection.
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.
Details about the state of a replicator.
Information about a replicator.
The details of the Amazon S3 destination for broker logs.
Describes the serverless cluster.
Describes the serverless cluster client authentication.
Creates serverless cluster.
Describes the serverless cluster SASL information.
Returns information about an error.
Contains information about the state of the Amazon MSK cluster.
Contains information about storage volumes attached to MSK broker nodes.
Tag a resource.
Details for client authentication using TLS.
Returns information about an error.
Details about topic replication.
Details for updating the topic replication of a replicator.
Contains information about unauthenticated traffic to the cluster.
Returns information about an error.
Request body for UpdateBrokerCount.
Response body for UpdateBrokerCount.
Request object for UpdateBrokerStorage.
Response body for UpdateBrokerStorage.
Request body for UpdateBrokerType.
Response body for UpdateBrokerType.
Request body for UpdateClusterConfiguration.
Response body for UpdateClusterConfiguration.
Request body for UpdateClusterKafkaVersion.
Response body for UpdateClusterKafkaVersion.
Request body for UpdateConfiguration.
Response body for UpdateConfiguration.
Request body for UpdateConnectivity.
Response body for UpdateConnectivity.
Request body for UpdateMonitoring.
Response body for UpdateMonitoring.
Parameters for updating replication information between source and target Kafka clusters of a replicator.
Updated Replication information of a replicator.
Request body for UpdateSecurity.
Response body for UpdateSecurity.
Request object for UpdateStorageApi.
Response body for UpdateStorageResponse Api.
Description of the requester that calls the API operation.
The configuration of the Amazon VPCs for the cluster.
The VPC connection object.
Description of the VPC connection for CreateVpcConnection and DeleteVpcConnection operations.
Description of the VPC connection for CreateVpcConnection and DeleteVpcConnection operations.
Broker VPC connectivity access control.
Zookeeper node information.