@ThreadSafe @Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class AWSKafkaConnectClient extends AmazonWebServiceClient implements AWSKafkaConnect
LOGGING_AWS_REQUEST_METRIC
ENDPOINT_PREFIX
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.
|
DeleteWorkerConfigurationResult |
deleteWorkerConfiguration(DeleteWorkerConfigurationRequest request)
Deletes the specified worker configuration.
|
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.
|
ListTagsForResourceResult |
listTagsForResource(ListTagsForResourceRequest request)
Lists all the tags attached to the specified resource.
|
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.
|
TagResourceResult |
tagResource(TagResourceRequest request)
Attaches tags to the specified resource.
|
UntagResourceResult |
untagResource(UntagResourceRequest request)
Removes tags from the specified resource.
|
UpdateConnectorResult |
updateConnector(UpdateConnectorRequest request)
Updates the specified connector.
|
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
public static AWSKafkaConnectClientBuilder builder()
public CreateConnectorResult createConnector(CreateConnectorRequest request)
Creates a connector using the specified properties.
createConnector
in interface AWSKafkaConnect
createConnectorRequest
- 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.public CreateCustomPluginResult createCustomPlugin(CreateCustomPluginRequest request)
Creates a custom plugin using the specified properties.
createCustomPlugin
in interface AWSKafkaConnect
createCustomPluginRequest
- 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.public CreateWorkerConfigurationResult createWorkerConfiguration(CreateWorkerConfigurationRequest request)
Creates a worker configuration using the specified properties.
createWorkerConfiguration
in interface AWSKafkaConnect
createWorkerConfigurationRequest
- 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.public DeleteConnectorResult deleteConnector(DeleteConnectorRequest request)
Deletes the specified connector.
deleteConnector
in interface AWSKafkaConnect
deleteConnectorRequest
- 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.public DeleteCustomPluginResult deleteCustomPlugin(DeleteCustomPluginRequest request)
Deletes a custom plugin.
deleteCustomPlugin
in interface AWSKafkaConnect
deleteCustomPluginRequest
- 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.public DeleteWorkerConfigurationResult deleteWorkerConfiguration(DeleteWorkerConfigurationRequest request)
Deletes the specified worker configuration.
deleteWorkerConfiguration
in interface AWSKafkaConnect
deleteWorkerConfigurationRequest
- 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.public DescribeConnectorResult describeConnector(DescribeConnectorRequest request)
Returns summary information about the connector.
describeConnector
in interface AWSKafkaConnect
describeConnectorRequest
- 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.public DescribeCustomPluginResult describeCustomPlugin(DescribeCustomPluginRequest request)
A summary description of the custom plugin.
describeCustomPlugin
in interface AWSKafkaConnect
describeCustomPluginRequest
- 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.public DescribeWorkerConfigurationResult describeWorkerConfiguration(DescribeWorkerConfigurationRequest request)
Returns information about a worker configuration.
describeWorkerConfiguration
in interface AWSKafkaConnect
describeWorkerConfigurationRequest
- 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.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.
listConnectors
in interface AWSKafkaConnect
listConnectorsRequest
- 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.public ListCustomPluginsResult listCustomPlugins(ListCustomPluginsRequest request)
Returns a list of all of the custom plugins in this account and Region.
listCustomPlugins
in interface AWSKafkaConnect
listCustomPluginsRequest
- 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.public ListTagsForResourceResult listTagsForResource(ListTagsForResourceRequest request)
Lists all the tags attached to the specified resource.
listTagsForResource
in interface AWSKafkaConnect
listTagsForResourceRequest
- 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.public ListWorkerConfigurationsResult listWorkerConfigurations(ListWorkerConfigurationsRequest request)
Returns a list of all of the worker configurations in this account and Region.
listWorkerConfigurations
in interface AWSKafkaConnect
listWorkerConfigurationsRequest
- 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.public TagResourceResult tagResource(TagResourceRequest request)
Attaches tags to the specified resource.
tagResource
in interface AWSKafkaConnect
tagResourceRequest
- 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.public UntagResourceResult untagResource(UntagResourceRequest request)
Removes tags from the specified resource.
untagResource
in interface AWSKafkaConnect
untagResourceRequest
- 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.public UpdateConnectorResult updateConnector(UpdateConnectorRequest request)
Updates the specified connector.
updateConnector
in interface AWSKafkaConnect
updateConnectorRequest
- 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.public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request)
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.
getCachedResponseMetadata
in interface AWSKafkaConnect
request
- The originally executed requestpublic void shutdown()
AmazonWebServiceClient
shutdown
in interface AWSKafkaConnect
shutdown
in class AmazonWebServiceClient