kafkaconnect/aws.sdk.kotlin.services.kafkaconnect

Package-level declarations

Types

KafkaConnectClient

interface KafkaConnectClient : SdkClient

Properties

const val SdkVersion: String

ServiceApiVersion

const val ServiceApiVersion: String

const val ServiceId: String

Functions

createConnector

inline suspend fun KafkaConnectClient.createConnector(crossinline block: CreateConnectorRequest.Builder.() -> Unit): CreateConnectorResponse

Creates a connector using the specified properties.

createCustomPlugin

inline suspend fun KafkaConnectClient.createCustomPlugin(crossinline block: CreateCustomPluginRequest.Builder.() -> Unit): CreateCustomPluginResponse

Creates a custom plugin using the specified properties.

createWorkerConfiguration

inline suspend fun KafkaConnectClient.createWorkerConfiguration(crossinline block: CreateWorkerConfigurationRequest.Builder.() -> Unit): CreateWorkerConfigurationResponse

Creates a worker configuration using the specified properties.

deleteConnector

inline suspend fun KafkaConnectClient.deleteConnector(crossinline block: DeleteConnectorRequest.Builder.() -> Unit): DeleteConnectorResponse

Deletes the specified connector.

deleteCustomPlugin

inline suspend fun KafkaConnectClient.deleteCustomPlugin(crossinline block: DeleteCustomPluginRequest.Builder.() -> Unit): DeleteCustomPluginResponse

Deletes a custom plugin.

deleteWorkerConfiguration

inline suspend fun KafkaConnectClient.deleteWorkerConfiguration(crossinline block: DeleteWorkerConfigurationRequest.Builder.() -> Unit): DeleteWorkerConfigurationResponse

Deletes the specified worker configuration.

describeConnector

inline suspend fun KafkaConnectClient.describeConnector(crossinline block: DescribeConnectorRequest.Builder.() -> Unit): DescribeConnectorResponse

Returns summary information about the connector.

describeCustomPlugin

inline suspend fun KafkaConnectClient.describeCustomPlugin(crossinline block: DescribeCustomPluginRequest.Builder.() -> Unit): DescribeCustomPluginResponse

A summary description of the custom plugin.

describeWorkerConfiguration

inline suspend fun KafkaConnectClient.describeWorkerConfiguration(crossinline block: DescribeWorkerConfigurationRequest.Builder.() -> Unit): DescribeWorkerConfigurationResponse

Returns information about a worker configuration.

inline suspend fun KafkaConnectClient.listConnectors(crossinline block: ListConnectorsRequest.Builder.() -> Unit): ListConnectorsResponse

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.

listCustomPlugins

inline suspend fun KafkaConnectClient.listCustomPlugins(crossinline block: ListCustomPluginsRequest.Builder.() -> Unit): ListCustomPluginsResponse

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

listTagsForResource

inline suspend fun KafkaConnectClient.listTagsForResource(crossinline block: ListTagsForResourceRequest.Builder.() -> Unit): ListTagsForResourceResponse

Lists all the tags attached to the specified resource.

listWorkerConfigurations

inline suspend fun KafkaConnectClient.listWorkerConfigurations(crossinline block: ListWorkerConfigurationsRequest.Builder.() -> Unit): ListWorkerConfigurationsResponse

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

inline suspend fun KafkaConnectClient.tagResource(crossinline block: TagResourceRequest.Builder.() -> Unit): TagResourceResponse

Attaches tags to the specified resource.

inline suspend fun KafkaConnectClient.untagResource(crossinline block: UntagResourceRequest.Builder.() -> Unit): UntagResourceResponse

Removes tags from the specified resource.

updateConnector

inline suspend fun KafkaConnectClient.updateConnector(crossinline block: UpdateConnectorRequest.Builder.() -> Unit): UpdateConnectorResponse

Updates the specified connector.

fun KafkaConnectClient.withConfig(block: KafkaConnectClient.Config.Builder.() -> Unit): KafkaConnectClient

Create a copy of the client with one or more configuration values overridden. This method allows the caller to perform scoped config overrides for one or more client operations.