View Source AWS.KafkaConnect (aws-elixir v1.0.0)

Summary

Functions

create_connector(client, input, options \\ [])

Creates a connector using the specified properties.

create_custom_plugin(client, input, options \\ [])

Creates a custom plugin using the specified properties.

create_worker_configuration(client, input, options \\ [])

Creates a worker configuration using the specified properties.

delete_connector(client, connector_arn, input, options \\ [])

Deletes the specified connector.

delete_custom_plugin(client, custom_plugin_arn, input, options \\ [])

Deletes a custom plugin.

delete_worker_configuration(client, worker_configuration_arn, input, options \\ [])

Deletes the specified worker configuration.

describe_connector(client, connector_arn, options \\ [])

Returns summary information about the connector.

describe_custom_plugin(client, custom_plugin_arn, options \\ [])

A summary description of the custom plugin.

describe_worker_configuration(client, worker_configuration_arn, options \\ [])

Returns information about a worker configuration.

list_connectors(client, connector_name_prefix \\ nil, max_results \\ nil, next_token \\ nil, options \\ [])

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

list_custom_plugins(client, max_results \\ nil, name_prefix \\ nil, next_token \\ nil, options \\ [])

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

list_tags_for_resource(client, resource_arn, options \\ [])

Lists all the tags attached to the specified resource.

list_worker_configurations(client, max_results \\ nil, name_prefix \\ nil, next_token \\ nil, options \\ [])

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

metadata()

tag_resource(client, resource_arn, input, options \\ [])

Attaches tags to the specified resource.

untag_resource(client, resource_arn, input, options \\ [])

Removes tags from the specified resource.

update_connector(client, connector_arn, input, options \\ [])

Updates the specified connector.

Functions

create_connector(client, input, options \\ [])

Creates a connector using the specified properties.

create_custom_plugin(client, input, options \\ [])

Creates a custom plugin using the specified properties.

create_worker_configuration(client, input, options \\ [])

Creates a worker configuration using the specified properties.

delete_connector(client, connector_arn, input, options \\ [])

Deletes the specified connector.

delete_custom_plugin(client, custom_plugin_arn, input, options \\ [])

Deletes a custom plugin.

delete_worker_configuration(client, worker_configuration_arn, input, options \\ [])

Deletes the specified worker configuration.

describe_connector(client, connector_arn, options \\ [])

Returns summary information about the connector.

describe_custom_plugin(client, custom_plugin_arn, options \\ [])

A summary description of the custom plugin.

describe_worker_configuration(client, worker_configuration_arn, options \\ [])

Returns information about a worker configuration.

list_connectors(client, connector_name_prefix \\ nil, max_results \\ nil, next_token \\ nil, options \\ [])

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.

list_custom_plugins(client, max_results \\ nil, name_prefix \\ nil, next_token \\ nil, options \\ [])

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

list_tags_for_resource(client, resource_arn, options \\ [])

Lists all the tags attached to the specified resource.

list_worker_configurations(client, max_results \\ nil, name_prefix \\ nil, next_token \\ nil, options \\ [])

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

metadata()

tag_resource(client, resource_arn, input, options \\ [])

Attaches tags to the specified resource.

untag_resource(client, resource_arn, input, options \\ [])

Removes tags from the specified resource.

update_connector(client, connector_arn, input, options \\ [])

Updates the specified connector.