com.amazonaws.services.kafkaconnect

Class AWSKafkaConnectClient

java.lang.Object

com.amazonaws.AmazonWebServiceClient

com.amazonaws.services.kafkaconnect.AWSKafkaConnectClient

All Implemented Interfaces:

AWSKafkaConnect

Direct Known Subclasses:

AWSKafkaConnectAsyncClient

@ThreadSafe
 @Generated(value="com.amazonaws:aws-java-sdk-code-generator")
public class AWSKafkaConnectClient
extends AmazonWebServiceClient
implements AWSKafkaConnect

Client for accessing Kafka Connect. All service calls made using this client are blocking, and will not return until the service call completes.

Field Summary

Fields inherited from class com.amazonaws.AmazonWebServiceClient

LOGGING_AWS_REQUEST_METRIC

Fields inherited from interface com.amazonaws.services.kafkaconnect.AWSKafkaConnect

ENDPOINT_PREFIX

Method Summary

Modifier and Type	Method and Description
static AWSKafkaConnectClientBuilder	builder()
CreateConnectorResult	createConnector(CreateConnectorRequest request) Creates a connector using the specified properties.
CreateCustomPluginResult	createCustomPlugin(CreateCustomPluginRequest request) Creates a custom plugin using the specified properties.
CreateWorkerConfigurationResult	createWorkerConfiguration(CreateWorkerConfigurationRequest request) Creates a worker configuration using the specified properties.
DeleteConnectorResult	deleteConnector(DeleteConnectorRequest request) Deletes the specified connector.
DeleteCustomPluginResult	deleteCustomPlugin(DeleteCustomPluginRequest request) Deletes a custom plugin.
DescribeConnectorResult	describeConnector(DescribeConnectorRequest request) Returns summary information about the connector.
DescribeCustomPluginResult	describeCustomPlugin(DescribeCustomPluginRequest request) A summary description of the custom plugin.
DescribeWorkerConfigurationResult	describeWorkerConfiguration(DescribeWorkerConfigurationRequest request) Returns information about a worker configuration.
ResponseMetadata	getCachedResponseMetadata(AmazonWebServiceRequest request) Returns additional metadata for a previously executed successful, request, typically used for debugging issues where a service isn't acting as expected.
ListConnectorsResult	listConnectors(ListConnectorsRequest request) Returns a list of all the connectors in this account and Region.
ListCustomPluginsResult	listCustomPlugins(ListCustomPluginsRequest request) Returns a list of all of the custom plugins in this account and Region.
ListWorkerConfigurationsResult	listWorkerConfigurations(ListWorkerConfigurationsRequest request) Returns a list of all of the worker configurations in this account and Region.
void	shutdown() Shuts down this client object, releasing any resources that might be held open.
UpdateConnectorResult	updateConnector(UpdateConnectorRequest request) Updates the specified connector.

Methods inherited from class com.amazonaws.AmazonWebServiceClient

addRequestHandler, addRequestHandler, configureRegion, getClientConfiguration, getEndpointPrefix, getMonitoringListeners, getRequestMetricsCollector, getServiceName, getSignerByURI, getSignerOverride, getSignerRegionOverride, getTimeOffset, makeImmutable, removeRequestHandler, removeRequestHandler, setEndpoint, setEndpoint, setRegion, setServiceNameIntern, setSignerRegionOverride, setTimeOffset, withEndpoint, withRegion, withRegion, withTimeOffset

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

builder

public static AWSKafkaConnectClientBuilder builder()

createConnector

public CreateConnectorResult createConnector(CreateConnectorRequest request)

Creates a connector using the specified properties.

Specified by:

createConnector in interface AWSKafkaConnect

Parameters:

createConnectorRequest -

Returns:

Result of the CreateConnector operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

ConflictException - HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

createCustomPlugin

public CreateCustomPluginResult createCustomPlugin(CreateCustomPluginRequest request)

Creates a custom plugin using the specified properties.

Specified by:

createCustomPlugin in interface AWSKafkaConnect

Parameters:

createCustomPluginRequest -

Returns:

Result of the CreateCustomPlugin operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

ConflictException - HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

createWorkerConfiguration

public CreateWorkerConfigurationResult createWorkerConfiguration(CreateWorkerConfigurationRequest request)

Creates a worker configuration using the specified properties.

Specified by:

createWorkerConfiguration in interface AWSKafkaConnect

Parameters:

createWorkerConfigurationRequest -

Returns:

Result of the CreateWorkerConfiguration operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

ConflictException - HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

deleteConnector

public DeleteConnectorResult deleteConnector(DeleteConnectorRequest request)

Deletes the specified connector.

Specified by:

deleteConnector in interface AWSKafkaConnect

Parameters:

deleteConnectorRequest -

Returns:

Result of the DeleteConnector operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

deleteCustomPlugin

public DeleteCustomPluginResult deleteCustomPlugin(DeleteCustomPluginRequest request)

Deletes a custom plugin.

Specified by:

deleteCustomPlugin in interface AWSKafkaConnect

Parameters:

deleteCustomPluginRequest -

Returns:

Result of the DeleteCustomPlugin operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

describeConnector

public DescribeConnectorResult describeConnector(DescribeConnectorRequest request)

Returns summary information about the connector.

Specified by:

describeConnector in interface AWSKafkaConnect

Parameters:

describeConnectorRequest -

Returns:

Result of the DescribeConnector operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

describeCustomPlugin

public DescribeCustomPluginResult describeCustomPlugin(DescribeCustomPluginRequest request)

A summary description of the custom plugin.

Specified by:

describeCustomPlugin in interface AWSKafkaConnect

Parameters:

describeCustomPluginRequest -

Returns:

Result of the DescribeCustomPlugin operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

describeWorkerConfiguration

public DescribeWorkerConfigurationResult describeWorkerConfiguration(DescribeWorkerConfigurationRequest request)

Returns information about a worker configuration.

Specified by:

describeWorkerConfiguration in interface AWSKafkaConnect

Parameters:

describeWorkerConfigurationRequest -

Returns:

Result of the DescribeWorkerConfiguration operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

listConnectors

public ListConnectorsResult listConnectors(ListConnectorsRequest request)

Returns a list of all the connectors in this account and Region. The list is limited to connectors whose name starts with the specified prefix. The response also includes a description of each of the listed connectors.

Specified by:

listConnectors in interface AWSKafkaConnect

Parameters:

listConnectorsRequest -

Returns:

Result of the ListConnectors operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

listCustomPlugins

public ListCustomPluginsResult listCustomPlugins(ListCustomPluginsRequest request)

Returns a list of all of the custom plugins in this account and Region.

Specified by:

listCustomPlugins in interface AWSKafkaConnect

Parameters:

listCustomPluginsRequest -

Returns:

Result of the ListCustomPlugins operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

listWorkerConfigurations

public ListWorkerConfigurationsResult listWorkerConfigurations(ListWorkerConfigurationsRequest request)

Returns a list of all of the worker configurations in this account and Region.

Specified by:

listWorkerConfigurations in interface AWSKafkaConnect

Parameters:

listWorkerConfigurationsRequest -

Returns:

Result of the ListWorkerConfigurations operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

updateConnector

public UpdateConnectorResult updateConnector(UpdateConnectorRequest request)

Updates the specified connector.

Specified by:

updateConnector in interface AWSKafkaConnect

Parameters:

updateConnectorRequest -

Returns:

Result of the UpdateConnector operation returned by the service.

Throws:

NotFoundException - HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

BadRequestException - HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

ForbiddenException - HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

ServiceUnavailableException - HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

TooManyRequestsException - HTTP Status Code 429: Limit exceeded. Resource limit reached.

UnauthorizedException - HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

InternalServerErrorException - HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

See Also:

AWS API Documentation

getCachedResponseMetadata

public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request)

Returns additional metadata for a previously executed successful, request, typically used for debugging issues where a service isn't acting as expected. This data isn't considered part of the result data returned by an operation, so it's available through this separate, diagnostic interface.

Response metadata is only cached for a limited period of time, so if you need to access this extra diagnostic information for an executed request, you should use this method to retrieve it as soon as possible after executing the request.

Specified by:

getCachedResponseMetadata in interface AWSKafkaConnect

Parameters:

request - The originally executed request

Returns:

The response metadata for the specified request, or null if none is available.

shutdown

public void shutdown()

Description copied from class: AmazonWebServiceClient

Shuts down this client object, releasing any resources that might be held open. If this method is not invoked, resources may be leaked. Once a client has been shutdown, it should not be used to make any more requests.

Specified by:

shutdown in interface AWSKafkaConnect

Overrides:

shutdown in class AmazonWebServiceClient