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 Kafka client with a session.

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.

ClusterStateUpdating is a ClusterState 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.

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

NodeTypeBroker is a NodeType enum value.

ServiceID is a unique identifer of a specific service.

Name of service.

Specifies the EBS volume upgrade information.

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

BrokerNodeInfo.

Information about the current software installed on the cluster.

Includes all client authentication information.

Returns information about a cluster.

Returns information about a cluster operation.

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.

Request body for CreateConfiguration.

Response body for CreateConfiguration.

Returns information about the deleted cluster.

Information about a cluster operation.

Returns information about a cluster.

Response body for DescribeConfiguration.

Response body for DescribeConfigurationRevision.

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.

Returns a string containing one or more hostname:port pairs.

Kafka provides the API operation methods for making requests to Managed Streaming for Kafka.

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.

Information about revisions of an MSK configuration.

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

Information about nodes in the cluster.

Response of listing tags for a resource.

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

The node information object.

Contains information about storage volumes attached to MSK broker nodes.

Tag a resource.

Details for client authentication using TLS.

Request object for UpdateBrokerStorage.

Response body for UpdateBrokerStorage.

Request body for UpdateClusterConfiguration.

Response body for UpdateClusterConfiguration.

Zookeeper node information.