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

New creates a new instance of the client from the provided Config.

NewListClusterOperationsRequestPaginator returns a paginator for ListClusterOperations.

NewListClustersRequestPaginator returns a paginator for ListClusters.

NewListConfigurationRevisionsRequestPaginator returns a paginator for ListConfigurationRevisions.

NewListConfigurationsRequestPaginator returns a paginator for ListConfigurations.

NewListKafkaVersionsRequestPaginator returns a paginator for ListKafkaVersions.

NewListNodesRequestPaginator returns a paginator for ListNodes.

Enum values for BrokerAZDistribution.

Enum values for Broker.

Enum values for Broker.

Enum values for Broker.

Enum values for ClusterState.

Enum values for ClusterState.

Enum values for ClusterState.

Enum values for ClusterState.

Enum values for ClusterState.

Service's Endpoint identifier.

Enum values for EnhancedMonitoring.

Enum values for EnhancedMonitoring.

Enum values for EnhancedMonitoring.

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

Enum values for KafkaVersionStatus.

Enum values for KafkaVersionStatus.

Enum values for NodeType.

Service's identifier.

Service's name.

Includes all client authentication information.

Specifies the EBS volume upgrade information.

The broker logs configuration for this MSK cluster.

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

BrokerNodeInfo.

Information about the current software installed on the cluster.

Client provides the API operation methods for making requests to Kafka.

Details of the CloudWatch Logs destination for broker logs.

Returns information about a cluster.

Returns information about a cluster operation.

Step taken during a cluster operation.

State information about the operation step.

Contains source Kafka versions and compatible target Kafka versions.

Represents an MSK Configuration.

Specifies the configuration to use for the brokers.

Describes a configuration revision.

Creates a cluster.

Returns information about the created cluster.

CreateClusterRequest is the request type for the CreateCluster API operation.

CreateClusterResponse is the response type for the CreateCluster API operation.

Request body for CreateConfiguration.

Response body for CreateConfiguration.

CreateConfigurationRequest is the request type for the CreateConfiguration API operation.

CreateConfigurationResponse is the response type for the CreateConfiguration API operation.

Returns information about the deleted cluster.

DeleteClusterRequest is the request type for the DeleteCluster API operation.

DeleteClusterResponse is the response type for the DeleteCluster API operation.

Information about a cluster operation.

DescribeClusterOperationRequest is the request type for the DescribeClusterOperation API operation.

DescribeClusterOperationResponse is the response type for the DescribeClusterOperation API operation.

Returns information about a cluster.

DescribeClusterRequest is the request type for the DescribeCluster API operation.

DescribeClusterResponse is the response type for the DescribeCluster API operation.

Response body for DescribeConfiguration.

DescribeConfigurationRequest is the request type for the DescribeConfiguration API operation.

DescribeConfigurationResponse is the response type for the DescribeConfiguration API operation.

Response body for DescribeConfigurationRevision.

DescribeConfigurationRevisionRequest is the request type for the DescribeConfigurationRevision API operation.

DescribeConfigurationRevisionResponse is the response type for the DescribeConfigurationRevision API operation.

Contains information about the EBS storage volumes attached to 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 a string containing one or more hostname:port pairs.

GetBootstrapBrokersRequest is the request type for the GetBootstrapBrokers API operation.

GetBootstrapBrokersResponse is the response type for the GetBootstrapBrokers API operation.

Response body for GetCompatibleKafkaVersions.

GetCompatibleKafkaVersionsRequest is the request type for the GetCompatibleKafkaVersions API operation.

GetCompatibleKafkaVersionsResponse is the response type for the GetCompatibleKafkaVersions API operation.

Indicates whether you want to enable or disable the JMX Exporter.

Indicates whether you want to enable or disable the JMX Exporter.

Information about a Kafka version.

The response contains an array containing cluster operation information and a next token if the response is truncated.

ListClusterOperationsPaginator is used to paginate the request.

ListClusterOperationsRequest is the request type for the ListClusterOperations API operation.

ListClusterOperationsResponse is the response type for the ListClusterOperations API operation.

The response contains an array containing cluster information and a next token if the response is truncated.

ListClustersPaginator is used to paginate the request.

ListClustersRequest is the request type for the ListClusters API operation.

ListClustersResponse is the response type for the ListClusters API operation.

Information about revisions of an MSK configuration.

ListConfigurationRevisionsPaginator is used to paginate the request.

ListConfigurationRevisionsRequest is the request type for the ListConfigurationRevisions API operation.

ListConfigurationRevisionsResponse is the response type for the ListConfigurationRevisions API operation.

The response contains an array of Configuration and a next token if the response is truncated.

ListConfigurationsPaginator is used to paginate the request.

ListConfigurationsRequest is the request type for the ListConfigurations API operation.

ListConfigurationsResponse is the response type for the ListConfigurations API operation.

Response for ListKafkaVersions.

ListKafkaVersionsPaginator is used to paginate the request.

ListKafkaVersionsRequest is the request type for the ListKafkaVersions API operation.

ListKafkaVersionsResponse is the response type for the ListKafkaVersions API operation.

Information about nodes in the cluster.

ListNodesPaginator is used to paginate the request.

ListNodesRequest is the request type for the ListNodes API operation.

ListNodesResponse is the response type for the ListNodes API operation.

Response of listing tags for a resource.

ListTagsForResourceRequest is the request type for the ListTagsForResource API operation.

ListTagsForResourceResponse is the response type for the ListTagsForResource API operation.

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.

JMX and Node monitoring for the MSK cluster.

JMX and Node monitoring for the MSK cluster.

Prometheus settings for open monitoring.

Prometheus settings.

The details of the Amazon S3 destination for broker logs.

Contains information about storage volumes attached to MSK broker nodes.

Tag a resource.

TagResourceRequest is the request type for the TagResource API operation.

TagResourceResponse is the response type for the TagResource API operation.

Details for client authentication using TLS.

UntagResourceRequest is the request type for the UntagResource API operation.

UntagResourceResponse is the response type for the UntagResource API operation.

Request body for UpdateBrokerCount.

Response body for UpdateBrokerCount.

UpdateBrokerCountRequest is the request type for the UpdateBrokerCount API operation.

UpdateBrokerCountResponse is the response type for the UpdateBrokerCount API operation.

Request object for UpdateBrokerStorage.

Response body for UpdateBrokerStorage.

UpdateBrokerStorageRequest is the request type for the UpdateBrokerStorage API operation.

UpdateBrokerStorageResponse is the response type for the UpdateBrokerStorage API operation.

Request body for UpdateClusterConfiguration.

Response body for UpdateClusterConfiguration.

UpdateClusterConfigurationRequest is the request type for the UpdateClusterConfiguration API operation.

UpdateClusterConfigurationResponse is the response type for the UpdateClusterConfiguration API operation.

Request body for UpdateClusterKafkaVersion.

Response body for UpdateClusterKafkaVersion.

UpdateClusterKafkaVersionRequest is the request type for the UpdateClusterKafkaVersion API operation.

UpdateClusterKafkaVersionResponse is the response type for the UpdateClusterKafkaVersion API operation.

Request body for UpdateMonitoring.

Response body for UpdateMonitoring.

UpdateMonitoringRequest is the request type for the UpdateMonitoring API operation.

UpdateMonitoringResponse is the response type for the UpdateMonitoring API operation.

Zookeeper node information.

Client-broker encryption in transit setting.

The distribution of broker nodes across Availability Zones.

The state of a Kafka cluster.

Specifies which metrics are gathered for the MSK cluster.

The status of a Kafka version.

The broker or Zookeeper node.