# Packages
Package kafkaconnectiface provides an interface to enable mocking the Managed Streaming for Kafka Connect service client for testing your code.
# Functions
ConnectorState_Values returns all elements of the ConnectorState enum.
CustomPluginContentType_Values returns all elements of the CustomPluginContentType enum.
CustomPluginState_Values returns all elements of the CustomPluginState enum.
KafkaClusterClientAuthenticationType_Values returns all elements of the KafkaClusterClientAuthenticationType enum.
KafkaClusterEncryptionInTransitType_Values returns all elements of the KafkaClusterEncryptionInTransitType enum.
New creates a new instance of the KafkaConnect client with a session.
WorkerConfigurationState_Values returns all elements of the WorkerConfigurationState enum.
# Constants
ConnectorStateCreating is a ConnectorState enum value.
ConnectorStateDeleting is a ConnectorState enum value.
ConnectorStateFailed is a ConnectorState enum value.
ConnectorStateRunning is a ConnectorState enum value.
ConnectorStateUpdating is a ConnectorState enum value.
CustomPluginContentTypeJar is a CustomPluginContentType enum value.
CustomPluginContentTypeZip is a CustomPluginContentType enum value.
CustomPluginStateActive is a CustomPluginState enum value.
CustomPluginStateCreateFailed is a CustomPluginState enum value.
CustomPluginStateCreating is a CustomPluginState enum value.
CustomPluginStateDeleting is a CustomPluginState enum value.
CustomPluginStateUpdateFailed is a CustomPluginState enum value.
CustomPluginStateUpdating is a CustomPluginState enum value.
ID to lookup a service endpoint with.
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".
KafkaClusterClientAuthenticationTypeIam is a KafkaClusterClientAuthenticationType enum value.
KafkaClusterClientAuthenticationTypeNone is a KafkaClusterClientAuthenticationType enum value.
KafkaClusterEncryptionInTransitTypePlaintext is a KafkaClusterEncryptionInTransitType enum value.
KafkaClusterEncryptionInTransitTypeTls is a KafkaClusterEncryptionInTransitType enum value.
ServiceID is a unique identifier of a specific service.
Name of service.
WorkerConfigurationStateActive is a WorkerConfigurationState enum value.
WorkerConfigurationStateDeleting is a WorkerConfigurationState enum value.
# Structs
The details of the Apache Kafka cluster to which the connector is connected.
The description of the Apache Kafka cluster to which the connector is connected.
Specifies how the connector scales.
Information about the auto scaling parameters for the connector.
The updates to the auto scaling parameters for the connector.
HTTP Status Code 400: Bad request due to incorrect input.
Information about the capacity of the connector, whether it is auto scaled or provisioned.
A description of the connector's capacity.
The target capacity for the connector.
The settings for delivering connector logs to Amazon CloudWatch Logs.
A description of the log delivery settings.
HTTP Status Code 409: Conflict.
Summary of a connector.
A plugin is an Amazon Web Services resource that contains the code that defines a connector's logic.
Details about a custom plugin.
Details about a custom plugin file.
Information about the location of a custom plugin.
Information about the location of a custom plugin.
Details about the revision of a custom plugin.
A summary of the custom plugin.
The settings for delivering logs to Amazon Kinesis Data Firehose.
A description of the settings for delivering logs to Amazon Kinesis Data Firehose.
HTTP Status Code 403: Access forbidden.
HTTP Status Code 500: Unexpected internal server error.
The details of the Apache Kafka cluster to which the connector is connected.
The client authentication information used in order to authenticate with the Apache Kafka cluster.
The client authentication information used in order to authenticate with the Apache Kafka cluster.
Details of how to connect to the Apache Kafka cluster.
Details of encryption in transit to the Apache Kafka cluster.
The description of the encryption in transit to the Apache Kafka cluster.
KafkaConnect provides the API operation methods for making requests to Managed Streaming for Kafka Connect.
Details about log delivery.
The description of the log delivery settings.
HTTP Status Code 404: Resource not found due to incorrect input.
A plugin is an Amazon Web Services resource that contains the code that defines your connector logic.
The description of the plugin.
Details about a connector's provisioned capacity.
The description of a connector's provisioned capacity.
An update to a connector's fixed capacity.
The location of an object in Amazon S3.
The description of the location of an object in Amazon S3.
Details about delivering logs to Amazon S3.
The description of the details about delivering logs to Amazon S3.
The scale-in policy for the connector.
The description of the scale-in policy for the connector.
An update to the connector's scale-in policy.
The scale-out policy for the connector.
The description of the scale-out policy for the connector.
An update to the connector's scale-out policy.
HTTP Status Code 503: Service Unavailable.
Details about the state of a resource.
HTTP Status Code 429: Limit exceeded.
HTTP Status Code 401: Unauthorized request.
Information about the VPC in which the connector resides.
The description of the VPC in which the connector resides.
The configuration of the workers, which are the processes that run the connector logic.
The description of the worker configuration.
The description of the worker configuration revision.
The summary of a worker configuration revision.
The summary of a worker configuration.
Workers can send worker logs to different destination types.
Workers can send worker logs to different destination types.