Package kafkaiface provides an interface to enable mocking the Managed Streaming for Kafka service client for testing your code.

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.

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.

StorageMode_Values returns all elements of the StorageMode enum.

UserIdentityType_Values returns all elements of the UserIdentityType enum.

VpcConnectionState_Values returns all elements of the VpcConnectionState enum.

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.

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.

ServiceID is a unique identifier of a specific service.

Name of service.

StorageModeLocal is a StorageMode enum value.

StorageModeTiered is a StorageMode 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.

Returns information about an error.

Request body for BatchAssociateScramSecret.

Response body for BatchAssociateScramSecret.

Request body for BatchDisassociateScramSecret.

Response body for BatchDisassociateScramSecret.

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.

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 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.

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 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 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.

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.

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.

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.

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.