Skip to content

KafkaConnectClient#

Index > KafkaConnect > KafkaConnectClient

Auto-generated documentation for KafkaConnect type annotations stubs module types-boto3-kafkaconnect.

KafkaConnectClient#

Type annotations and code completion for boto3.client("kafkaconnect"). boto3 documentation

# KafkaConnectClient usage example

from boto3.session import Session
from types_boto3_kafkaconnect.client import KafkaConnectClient

def get_kafkaconnect_client() -> KafkaConnectClient:
    return Session().client("kafkaconnect")

Exceptions#

boto3 client exceptions are generated in runtime. This class provides code completion for boto3.client("kafkaconnect").exceptions structure.

# Exceptions.exceptions usage example

client = boto3.client("kafkaconnect")

try:
    do_something(client)
except (
    client.exceptions.BadRequestException,
    client.exceptions.ClientError,
    client.exceptions.ConflictException,
    client.exceptions.ForbiddenException,
    client.exceptions.InternalServerErrorException,
    client.exceptions.NotFoundException,
    client.exceptions.ServiceUnavailableException,
    client.exceptions.TooManyRequestsException,
    client.exceptions.UnauthorizedException,
) as e:
    print(e)
# Exceptions.exceptions type checking example

from types_boto3_kafkaconnect.client import Exceptions

def handle_error(exc: Exceptions.BadRequestException) -> None:
    ...

Methods#

can_paginate#

Type annotations and code completion for boto3.client("kafkaconnect").can_paginate method. boto3 documentation

# can_paginate method definition

def can_paginate(
    self,
    operation_name: str,
) -> bool:
    ...

generate_presigned_url#

Type annotations and code completion for boto3.client("kafkaconnect").generate_presigned_url method. boto3 documentation

# generate_presigned_url method definition

def generate_presigned_url(
    self,
    ClientMethod: str,
    Params: Mapping[str, Any] = ...,
    ExpiresIn: int = 3600,
    HttpMethod: str = ...,
) -> str:
    ...

create_connector#

Creates a connector using the specified properties.

Type annotations and code completion for boto3.client("kafkaconnect").create_connector method. boto3 documentation

# create_connector method definition

def create_connector(
    self,
    *,
    capacity: CapacityTypeDef,  # (1)
    connectorConfiguration: Mapping[str, str],
    connectorName: str,
    kafkaCluster: KafkaClusterTypeDef,  # (2)
    kafkaClusterClientAuthentication: KafkaClusterClientAuthenticationTypeDef,  # (3)
    kafkaClusterEncryptionInTransit: KafkaClusterEncryptionInTransitTypeDef,  # (4)
    kafkaConnectVersion: str,
    plugins: Sequence[PluginTypeDef],  # (5)
    serviceExecutionRoleArn: str,
    connectorDescription: str = ...,
    logDelivery: LogDeliveryTypeDef = ...,  # (6)
    workerConfiguration: WorkerConfigurationTypeDef = ...,  # (7)
    tags: Mapping[str, str] = ...,
) -> CreateConnectorResponseTypeDef:  # (8)
    ...
  1. See CapacityTypeDef
  2. See KafkaClusterTypeDef
  3. See KafkaClusterClientAuthenticationTypeDef
  4. See KafkaClusterEncryptionInTransitTypeDef
  5. See Sequence[PluginTypeDef]
  6. See LogDeliveryTypeDef
  7. See WorkerConfigurationTypeDef
  8. See CreateConnectorResponseTypeDef
# create_connector method usage example with argument unpacking

kwargs: CreateConnectorRequestTypeDef = {  # (1)
    "capacity": ...,
    "connectorConfiguration": ...,
    "connectorName": ...,
    "kafkaCluster": ...,
    "kafkaClusterClientAuthentication": ...,
    "kafkaClusterEncryptionInTransit": ...,
    "kafkaConnectVersion": ...,
    "plugins": ...,
    "serviceExecutionRoleArn": ...,
}

parent.create_connector(**kwargs)
  1. See CreateConnectorRequestTypeDef

create_custom_plugin#

Creates a custom plugin using the specified properties.

Type annotations and code completion for boto3.client("kafkaconnect").create_custom_plugin method. boto3 documentation

# create_custom_plugin method definition

def create_custom_plugin(
    self,
    *,
    contentType: CustomPluginContentTypeType,  # (1)
    location: CustomPluginLocationTypeDef,  # (2)
    name: str,
    description: str = ...,
    tags: Mapping[str, str] = ...,
) -> CreateCustomPluginResponseTypeDef:  # (3)
    ...
  1. See CustomPluginContentTypeType
  2. See CustomPluginLocationTypeDef
  3. See CreateCustomPluginResponseTypeDef
# create_custom_plugin method usage example with argument unpacking

kwargs: CreateCustomPluginRequestTypeDef = {  # (1)
    "contentType": ...,
    "location": ...,
    "name": ...,
}

parent.create_custom_plugin(**kwargs)
  1. See CreateCustomPluginRequestTypeDef

create_worker_configuration#

Creates a worker configuration using the specified properties.

Type annotations and code completion for boto3.client("kafkaconnect").create_worker_configuration method. boto3 documentation

# create_worker_configuration method definition

def create_worker_configuration(
    self,
    *,
    name: str,
    propertiesFileContent: str,
    description: str = ...,
    tags: Mapping[str, str] = ...,
) -> CreateWorkerConfigurationResponseTypeDef:  # (1)
    ...
  1. See CreateWorkerConfigurationResponseTypeDef
# create_worker_configuration method usage example with argument unpacking

kwargs: CreateWorkerConfigurationRequestTypeDef = {  # (1)
    "name": ...,
    "propertiesFileContent": ...,
}

parent.create_worker_configuration(**kwargs)
  1. See CreateWorkerConfigurationRequestTypeDef

delete_connector#

Deletes the specified connector.

Type annotations and code completion for boto3.client("kafkaconnect").delete_connector method. boto3 documentation

# delete_connector method definition

def delete_connector(
    self,
    *,
    connectorArn: str,
    currentVersion: str = ...,
) -> DeleteConnectorResponseTypeDef:  # (1)
    ...
  1. See DeleteConnectorResponseTypeDef
# delete_connector method usage example with argument unpacking

kwargs: DeleteConnectorRequestTypeDef = {  # (1)
    "connectorArn": ...,
}

parent.delete_connector(**kwargs)
  1. See DeleteConnectorRequestTypeDef

delete_custom_plugin#

Deletes a custom plugin.

Type annotations and code completion for boto3.client("kafkaconnect").delete_custom_plugin method. boto3 documentation

# delete_custom_plugin method definition

def delete_custom_plugin(
    self,
    *,
    customPluginArn: str,
) -> DeleteCustomPluginResponseTypeDef:  # (1)
    ...
  1. See DeleteCustomPluginResponseTypeDef
# delete_custom_plugin method usage example with argument unpacking

kwargs: DeleteCustomPluginRequestTypeDef = {  # (1)
    "customPluginArn": ...,
}

parent.delete_custom_plugin(**kwargs)
  1. See DeleteCustomPluginRequestTypeDef

delete_worker_configuration#

Deletes the specified worker configuration.

Type annotations and code completion for boto3.client("kafkaconnect").delete_worker_configuration method. boto3 documentation

# delete_worker_configuration method definition

def delete_worker_configuration(
    self,
    *,
    workerConfigurationArn: str,
) -> DeleteWorkerConfigurationResponseTypeDef:  # (1)
    ...
  1. See DeleteWorkerConfigurationResponseTypeDef
# delete_worker_configuration method usage example with argument unpacking

kwargs: DeleteWorkerConfigurationRequestTypeDef = {  # (1)
    "workerConfigurationArn": ...,
}

parent.delete_worker_configuration(**kwargs)
  1. See DeleteWorkerConfigurationRequestTypeDef

describe_connector#

Returns summary information about the connector.

Type annotations and code completion for boto3.client("kafkaconnect").describe_connector method. boto3 documentation

# describe_connector method definition

def describe_connector(
    self,
    *,
    connectorArn: str,
) -> DescribeConnectorResponseTypeDef:  # (1)
    ...
  1. See DescribeConnectorResponseTypeDef
# describe_connector method usage example with argument unpacking

kwargs: DescribeConnectorRequestTypeDef = {  # (1)
    "connectorArn": ...,
}

parent.describe_connector(**kwargs)
  1. See DescribeConnectorRequestTypeDef

describe_connector_operation#

Returns information about the specified connector's operations.

Type annotations and code completion for boto3.client("kafkaconnect").describe_connector_operation method. boto3 documentation

# describe_connector_operation method definition

def describe_connector_operation(
    self,
    *,
    connectorOperationArn: str,
) -> DescribeConnectorOperationResponseTypeDef:  # (1)
    ...
  1. See DescribeConnectorOperationResponseTypeDef
# describe_connector_operation method usage example with argument unpacking

kwargs: DescribeConnectorOperationRequestTypeDef = {  # (1)
    "connectorOperationArn": ...,
}

parent.describe_connector_operation(**kwargs)
  1. See DescribeConnectorOperationRequestTypeDef

describe_custom_plugin#

A summary description of the custom plugin.

Type annotations and code completion for boto3.client("kafkaconnect").describe_custom_plugin method. boto3 documentation

# describe_custom_plugin method definition

def describe_custom_plugin(
    self,
    *,
    customPluginArn: str,
) -> DescribeCustomPluginResponseTypeDef:  # (1)
    ...
  1. See DescribeCustomPluginResponseTypeDef
# describe_custom_plugin method usage example with argument unpacking

kwargs: DescribeCustomPluginRequestTypeDef = {  # (1)
    "customPluginArn": ...,
}

parent.describe_custom_plugin(**kwargs)
  1. See DescribeCustomPluginRequestTypeDef

describe_worker_configuration#

Returns information about a worker configuration.

Type annotations and code completion for boto3.client("kafkaconnect").describe_worker_configuration method. boto3 documentation

# describe_worker_configuration method definition

def describe_worker_configuration(
    self,
    *,
    workerConfigurationArn: str,
) -> DescribeWorkerConfigurationResponseTypeDef:  # (1)
    ...
  1. See DescribeWorkerConfigurationResponseTypeDef
# describe_worker_configuration method usage example with argument unpacking

kwargs: DescribeWorkerConfigurationRequestTypeDef = {  # (1)
    "workerConfigurationArn": ...,
}

parent.describe_worker_configuration(**kwargs)
  1. See DescribeWorkerConfigurationRequestTypeDef

list_connector_operations#

Lists information about a connector's operation(s).

Type annotations and code completion for boto3.client("kafkaconnect").list_connector_operations method. boto3 documentation

# list_connector_operations method definition

def list_connector_operations(
    self,
    *,
    connectorArn: str,
    maxResults: int = ...,
    nextToken: str = ...,
) -> ListConnectorOperationsResponseTypeDef:  # (1)
    ...
  1. See ListConnectorOperationsResponseTypeDef
# list_connector_operations method usage example with argument unpacking

kwargs: ListConnectorOperationsRequestTypeDef = {  # (1)
    "connectorArn": ...,
}

parent.list_connector_operations(**kwargs)
  1. See ListConnectorOperationsRequestTypeDef

list_connectors#

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

Type annotations and code completion for boto3.client("kafkaconnect").list_connectors method. boto3 documentation

# list_connectors method definition

def list_connectors(
    self,
    *,
    connectorNamePrefix: str = ...,
    maxResults: int = ...,
    nextToken: str = ...,
) -> ListConnectorsResponseTypeDef:  # (1)
    ...
  1. See ListConnectorsResponseTypeDef
# list_connectors method usage example with argument unpacking

kwargs: ListConnectorsRequestTypeDef = {  # (1)
    "connectorNamePrefix": ...,
}

parent.list_connectors(**kwargs)
  1. See ListConnectorsRequestTypeDef

list_custom_plugins#

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

Type annotations and code completion for boto3.client("kafkaconnect").list_custom_plugins method. boto3 documentation

# list_custom_plugins method definition

def list_custom_plugins(
    self,
    *,
    maxResults: int = ...,
    nextToken: str = ...,
    namePrefix: str = ...,
) -> ListCustomPluginsResponseTypeDef:  # (1)
    ...
  1. See ListCustomPluginsResponseTypeDef
# list_custom_plugins method usage example with argument unpacking

kwargs: ListCustomPluginsRequestTypeDef = {  # (1)
    "maxResults": ...,
}

parent.list_custom_plugins(**kwargs)
  1. See ListCustomPluginsRequestTypeDef

list_tags_for_resource#

Lists all the tags attached to the specified resource.

Type annotations and code completion for boto3.client("kafkaconnect").list_tags_for_resource method. boto3 documentation

# list_tags_for_resource method definition

def list_tags_for_resource(
    self,
    *,
    resourceArn: str,
) -> ListTagsForResourceResponseTypeDef:  # (1)
    ...
  1. See ListTagsForResourceResponseTypeDef
# list_tags_for_resource method usage example with argument unpacking

kwargs: ListTagsForResourceRequestTypeDef = {  # (1)
    "resourceArn": ...,
}

parent.list_tags_for_resource(**kwargs)
  1. See ListTagsForResourceRequestTypeDef

list_worker_configurations#

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

Type annotations and code completion for boto3.client("kafkaconnect").list_worker_configurations method. boto3 documentation

# list_worker_configurations method definition

def list_worker_configurations(
    self,
    *,
    maxResults: int = ...,
    nextToken: str = ...,
    namePrefix: str = ...,
) -> ListWorkerConfigurationsResponseTypeDef:  # (1)
    ...
  1. See ListWorkerConfigurationsResponseTypeDef
# list_worker_configurations method usage example with argument unpacking

kwargs: ListWorkerConfigurationsRequestTypeDef = {  # (1)
    "maxResults": ...,
}

parent.list_worker_configurations(**kwargs)
  1. See ListWorkerConfigurationsRequestTypeDef

tag_resource#

Attaches tags to the specified resource.

Type annotations and code completion for boto3.client("kafkaconnect").tag_resource method. boto3 documentation

# tag_resource method definition

def tag_resource(
    self,
    *,
    resourceArn: str,
    tags: Mapping[str, str],
) -> Dict[str, Any]:
    ...
# tag_resource method usage example with argument unpacking

kwargs: TagResourceRequestTypeDef = {  # (1)
    "resourceArn": ...,
    "tags": ...,
}

parent.tag_resource(**kwargs)
  1. See TagResourceRequestTypeDef

untag_resource#

Removes tags from the specified resource.

Type annotations and code completion for boto3.client("kafkaconnect").untag_resource method. boto3 documentation

# untag_resource method definition

def untag_resource(
    self,
    *,
    resourceArn: str,
    tagKeys: Sequence[str],
) -> Dict[str, Any]:
    ...
# untag_resource method usage example with argument unpacking

kwargs: UntagResourceRequestTypeDef = {  # (1)
    "resourceArn": ...,
    "tagKeys": ...,
}

parent.untag_resource(**kwargs)
  1. See UntagResourceRequestTypeDef

update_connector#

Updates the specified connector.

Type annotations and code completion for boto3.client("kafkaconnect").update_connector method. boto3 documentation

# update_connector method definition

def update_connector(
    self,
    *,
    connectorArn: str,
    currentVersion: str,
    capacity: CapacityUpdateTypeDef = ...,  # (1)
    connectorConfiguration: Mapping[str, str] = ...,
) -> UpdateConnectorResponseTypeDef:  # (2)
    ...
  1. See CapacityUpdateTypeDef
  2. See UpdateConnectorResponseTypeDef
# update_connector method usage example with argument unpacking

kwargs: UpdateConnectorRequestTypeDef = {  # (1)
    "connectorArn": ...,
    "currentVersion": ...,
}

parent.update_connector(**kwargs)
  1. See UpdateConnectorRequestTypeDef

get_paginator#

Type annotations and code completion for boto3.client("kafkaconnect").get_paginator method with overloads.