Skip to content

Typed dictionaries#

Index > KafkaConnect > Typed dictionaries

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

VpcDescriptionTypeDef#

# VpcDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import VpcDescriptionTypeDef

def get_value() -> VpcDescriptionTypeDef:
    return {
        "securityGroups": ...,
    }
# VpcDescriptionTypeDef definition

class VpcDescriptionTypeDef(TypedDict):
    securityGroups: NotRequired[List[str]],
    subnets: NotRequired[List[str]],

VpcTypeDef#

# VpcTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import VpcTypeDef

def get_value() -> VpcTypeDef:
    return {
        "subnets": ...,
    }
# VpcTypeDef definition

class VpcTypeDef(TypedDict):
    subnets: Sequence[str],
    securityGroups: NotRequired[Sequence[str]],

ScaleInPolicyDescriptionTypeDef#

# ScaleInPolicyDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ScaleInPolicyDescriptionTypeDef

def get_value() -> ScaleInPolicyDescriptionTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
# ScaleInPolicyDescriptionTypeDef definition

class ScaleInPolicyDescriptionTypeDef(TypedDict):
    cpuUtilizationPercentage: NotRequired[int],

ScaleOutPolicyDescriptionTypeDef#

# ScaleOutPolicyDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ScaleOutPolicyDescriptionTypeDef

def get_value() -> ScaleOutPolicyDescriptionTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
# ScaleOutPolicyDescriptionTypeDef definition

class ScaleOutPolicyDescriptionTypeDef(TypedDict):
    cpuUtilizationPercentage: NotRequired[int],

ScaleInPolicyTypeDef#

# ScaleInPolicyTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ScaleInPolicyTypeDef

def get_value() -> ScaleInPolicyTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
# ScaleInPolicyTypeDef definition

class ScaleInPolicyTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleOutPolicyTypeDef#

# ScaleOutPolicyTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ScaleOutPolicyTypeDef

def get_value() -> ScaleOutPolicyTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
# ScaleOutPolicyTypeDef definition

class ScaleOutPolicyTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleInPolicyUpdateTypeDef#

# ScaleInPolicyUpdateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ScaleInPolicyUpdateTypeDef

def get_value() -> ScaleInPolicyUpdateTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
# ScaleInPolicyUpdateTypeDef definition

class ScaleInPolicyUpdateTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleOutPolicyUpdateTypeDef#

# ScaleOutPolicyUpdateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ScaleOutPolicyUpdateTypeDef

def get_value() -> ScaleOutPolicyUpdateTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
# ScaleOutPolicyUpdateTypeDef definition

class ScaleOutPolicyUpdateTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ProvisionedCapacityDescriptionTypeDef#

# ProvisionedCapacityDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ProvisionedCapacityDescriptionTypeDef

def get_value() -> ProvisionedCapacityDescriptionTypeDef:
    return {
        "mcuCount": ...,
    }
# ProvisionedCapacityDescriptionTypeDef definition

class ProvisionedCapacityDescriptionTypeDef(TypedDict):
    mcuCount: NotRequired[int],
    workerCount: NotRequired[int],

ProvisionedCapacityTypeDef#

# ProvisionedCapacityTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ProvisionedCapacityTypeDef

def get_value() -> ProvisionedCapacityTypeDef:
    return {
        "mcuCount": ...,
        "workerCount": ...,
    }
# ProvisionedCapacityTypeDef definition

class ProvisionedCapacityTypeDef(TypedDict):
    mcuCount: int,
    workerCount: int,

ProvisionedCapacityUpdateTypeDef#

# ProvisionedCapacityUpdateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ProvisionedCapacityUpdateTypeDef

def get_value() -> ProvisionedCapacityUpdateTypeDef:
    return {
        "mcuCount": ...,
        "workerCount": ...,
    }
# ProvisionedCapacityUpdateTypeDef definition

class ProvisionedCapacityUpdateTypeDef(TypedDict):
    mcuCount: int,
    workerCount: int,

CloudWatchLogsLogDeliveryDescriptionTypeDef#

# CloudWatchLogsLogDeliveryDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryDescriptionTypeDef

def get_value() -> CloudWatchLogsLogDeliveryDescriptionTypeDef:
    return {
        "enabled": ...,
    }
# CloudWatchLogsLogDeliveryDescriptionTypeDef definition

class CloudWatchLogsLogDeliveryDescriptionTypeDef(TypedDict):
    enabled: NotRequired[bool],
    logGroup: NotRequired[str],

CloudWatchLogsLogDeliveryTypeDef#

# CloudWatchLogsLogDeliveryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryTypeDef

def get_value() -> CloudWatchLogsLogDeliveryTypeDef:
    return {
        "enabled": ...,
    }
# CloudWatchLogsLogDeliveryTypeDef definition

class CloudWatchLogsLogDeliveryTypeDef(TypedDict):
    enabled: bool,
    logGroup: NotRequired[str],

KafkaClusterClientAuthenticationDescriptionTypeDef#

# KafkaClusterClientAuthenticationDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import KafkaClusterClientAuthenticationDescriptionTypeDef

def get_value() -> KafkaClusterClientAuthenticationDescriptionTypeDef:
    return {
        "authenticationType": ...,
    }
# KafkaClusterClientAuthenticationDescriptionTypeDef definition

class KafkaClusterClientAuthenticationDescriptionTypeDef(TypedDict):
    authenticationType: NotRequired[KafkaClusterClientAuthenticationTypeType],  # (1)
  1. See KafkaClusterClientAuthenticationTypeType

KafkaClusterEncryptionInTransitDescriptionTypeDef#

# KafkaClusterEncryptionInTransitDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import KafkaClusterEncryptionInTransitDescriptionTypeDef

def get_value() -> KafkaClusterEncryptionInTransitDescriptionTypeDef:
    return {
        "encryptionType": ...,
    }
# KafkaClusterEncryptionInTransitDescriptionTypeDef definition

class KafkaClusterEncryptionInTransitDescriptionTypeDef(TypedDict):
    encryptionType: NotRequired[KafkaClusterEncryptionInTransitTypeType],  # (1)
  1. See KafkaClusterEncryptionInTransitTypeType

WorkerConfigurationDescriptionTypeDef#

# WorkerConfigurationDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationDescriptionTypeDef

def get_value() -> WorkerConfigurationDescriptionTypeDef:
    return {
        "revision": ...,
    }
# WorkerConfigurationDescriptionTypeDef definition

class WorkerConfigurationDescriptionTypeDef(TypedDict):
    revision: NotRequired[int],
    workerConfigurationArn: NotRequired[str],

KafkaClusterClientAuthenticationTypeDef#

# KafkaClusterClientAuthenticationTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import KafkaClusterClientAuthenticationTypeDef

def get_value() -> KafkaClusterClientAuthenticationTypeDef:
    return {
        "authenticationType": ...,
    }
# KafkaClusterClientAuthenticationTypeDef definition

class KafkaClusterClientAuthenticationTypeDef(TypedDict):
    authenticationType: KafkaClusterClientAuthenticationTypeType,  # (1)
  1. See KafkaClusterClientAuthenticationTypeType

KafkaClusterEncryptionInTransitTypeDef#

# KafkaClusterEncryptionInTransitTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import KafkaClusterEncryptionInTransitTypeDef

def get_value() -> KafkaClusterEncryptionInTransitTypeDef:
    return {
        "encryptionType": ...,
    }
# KafkaClusterEncryptionInTransitTypeDef definition

class KafkaClusterEncryptionInTransitTypeDef(TypedDict):
    encryptionType: KafkaClusterEncryptionInTransitTypeType,  # (1)
  1. See KafkaClusterEncryptionInTransitTypeType

WorkerConfigurationTypeDef#

# WorkerConfigurationTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationTypeDef

def get_value() -> WorkerConfigurationTypeDef:
    return {
        "revision": ...,
        "workerConfigurationArn": ...,
    }
# WorkerConfigurationTypeDef definition

class WorkerConfigurationTypeDef(TypedDict):
    revision: int,
    workerConfigurationArn: str,

CreateConnectorResponseTypeDef#

# CreateConnectorResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CreateConnectorResponseTypeDef

def get_value() -> CreateConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
        "connectorName": ...,
        "connectorState": ...,
        "ResponseMetadata": ...,
    }
# CreateConnectorResponseTypeDef definition

class CreateConnectorResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorName: str,
    connectorState: ConnectorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorStateType
  2. See ResponseMetadataTypeDef

CreateCustomPluginResponseTypeDef#

# CreateCustomPluginResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CreateCustomPluginResponseTypeDef

def get_value() -> CreateCustomPluginResponseTypeDef:
    return {
        "customPluginArn": ...,
        "customPluginState": ...,
        "name": ...,
        "revision": ...,
        "ResponseMetadata": ...,
    }
# CreateCustomPluginResponseTypeDef definition

class CreateCustomPluginResponseTypeDef(TypedDict):
    customPluginArn: str,
    customPluginState: CustomPluginStateType,  # (1)
    name: str,
    revision: int,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CustomPluginStateType
  2. See ResponseMetadataTypeDef

CreateWorkerConfigurationRequestRequestTypeDef#

# CreateWorkerConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CreateWorkerConfigurationRequestRequestTypeDef

def get_value() -> CreateWorkerConfigurationRequestRequestTypeDef:
    return {
        "name": ...,
        "propertiesFileContent": ...,
    }
# CreateWorkerConfigurationRequestRequestTypeDef definition

class CreateWorkerConfigurationRequestRequestTypeDef(TypedDict):
    name: str,
    propertiesFileContent: str,
    description: NotRequired[str],

WorkerConfigurationRevisionSummaryTypeDef#

# WorkerConfigurationRevisionSummaryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationRevisionSummaryTypeDef

def get_value() -> WorkerConfigurationRevisionSummaryTypeDef:
    return {
        "creationTime": ...,
    }
# WorkerConfigurationRevisionSummaryTypeDef definition

class WorkerConfigurationRevisionSummaryTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    revision: NotRequired[int],

CustomPluginDescriptionTypeDef#

# CustomPluginDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginDescriptionTypeDef

def get_value() -> CustomPluginDescriptionTypeDef:
    return {
        "customPluginArn": ...,
    }
# CustomPluginDescriptionTypeDef definition

class CustomPluginDescriptionTypeDef(TypedDict):
    customPluginArn: NotRequired[str],
    revision: NotRequired[int],

CustomPluginFileDescriptionTypeDef#

# CustomPluginFileDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginFileDescriptionTypeDef

def get_value() -> CustomPluginFileDescriptionTypeDef:
    return {
        "fileMd5": ...,
    }
# CustomPluginFileDescriptionTypeDef definition

class CustomPluginFileDescriptionTypeDef(TypedDict):
    fileMd5: NotRequired[str],
    fileSize: NotRequired[int],

S3LocationDescriptionTypeDef#

# S3LocationDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import S3LocationDescriptionTypeDef

def get_value() -> S3LocationDescriptionTypeDef:
    return {
        "bucketArn": ...,
    }
# S3LocationDescriptionTypeDef definition

class S3LocationDescriptionTypeDef(TypedDict):
    bucketArn: NotRequired[str],
    fileKey: NotRequired[str],
    objectVersion: NotRequired[str],

S3LocationTypeDef#

# S3LocationTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import S3LocationTypeDef

def get_value() -> S3LocationTypeDef:
    return {
        "bucketArn": ...,
        "fileKey": ...,
    }
# S3LocationTypeDef definition

class S3LocationTypeDef(TypedDict):
    bucketArn: str,
    fileKey: str,
    objectVersion: NotRequired[str],

CustomPluginTypeDef#

# CustomPluginTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginTypeDef

def get_value() -> CustomPluginTypeDef:
    return {
        "customPluginArn": ...,
        "revision": ...,
    }
# CustomPluginTypeDef definition

class CustomPluginTypeDef(TypedDict):
    customPluginArn: str,
    revision: int,

DeleteConnectorRequestRequestTypeDef#

# DeleteConnectorRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DeleteConnectorRequestRequestTypeDef

def get_value() -> DeleteConnectorRequestRequestTypeDef:
    return {
        "connectorArn": ...,
    }
# DeleteConnectorRequestRequestTypeDef definition

class DeleteConnectorRequestRequestTypeDef(TypedDict):
    connectorArn: str,
    currentVersion: NotRequired[str],

DeleteConnectorResponseTypeDef#

# DeleteConnectorResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DeleteConnectorResponseTypeDef

def get_value() -> DeleteConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
        "connectorState": ...,
        "ResponseMetadata": ...,
    }
# DeleteConnectorResponseTypeDef definition

class DeleteConnectorResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorState: ConnectorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorStateType
  2. See ResponseMetadataTypeDef

DeleteCustomPluginRequestRequestTypeDef#

# DeleteCustomPluginRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DeleteCustomPluginRequestRequestTypeDef

def get_value() -> DeleteCustomPluginRequestRequestTypeDef:
    return {
        "customPluginArn": ...,
    }
# DeleteCustomPluginRequestRequestTypeDef definition

class DeleteCustomPluginRequestRequestTypeDef(TypedDict):
    customPluginArn: str,

DeleteCustomPluginResponseTypeDef#

# DeleteCustomPluginResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DeleteCustomPluginResponseTypeDef

def get_value() -> DeleteCustomPluginResponseTypeDef:
    return {
        "customPluginArn": ...,
        "customPluginState": ...,
        "ResponseMetadata": ...,
    }
# DeleteCustomPluginResponseTypeDef definition

class DeleteCustomPluginResponseTypeDef(TypedDict):
    customPluginArn: str,
    customPluginState: CustomPluginStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CustomPluginStateType
  2. See ResponseMetadataTypeDef

DescribeConnectorRequestRequestTypeDef#

# DescribeConnectorRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DescribeConnectorRequestRequestTypeDef

def get_value() -> DescribeConnectorRequestRequestTypeDef:
    return {
        "connectorArn": ...,
    }
# DescribeConnectorRequestRequestTypeDef definition

class DescribeConnectorRequestRequestTypeDef(TypedDict):
    connectorArn: str,

StateDescriptionTypeDef#

# StateDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import StateDescriptionTypeDef

def get_value() -> StateDescriptionTypeDef:
    return {
        "code": ...,
    }
# StateDescriptionTypeDef definition

class StateDescriptionTypeDef(TypedDict):
    code: NotRequired[str],
    message: NotRequired[str],

DescribeCustomPluginRequestRequestTypeDef#

# DescribeCustomPluginRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DescribeCustomPluginRequestRequestTypeDef

def get_value() -> DescribeCustomPluginRequestRequestTypeDef:
    return {
        "customPluginArn": ...,
    }
# DescribeCustomPluginRequestRequestTypeDef definition

class DescribeCustomPluginRequestRequestTypeDef(TypedDict):
    customPluginArn: str,

DescribeWorkerConfigurationRequestRequestTypeDef#

# DescribeWorkerConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DescribeWorkerConfigurationRequestRequestTypeDef

def get_value() -> DescribeWorkerConfigurationRequestRequestTypeDef:
    return {
        "workerConfigurationArn": ...,
    }
# DescribeWorkerConfigurationRequestRequestTypeDef definition

class DescribeWorkerConfigurationRequestRequestTypeDef(TypedDict):
    workerConfigurationArn: str,

WorkerConfigurationRevisionDescriptionTypeDef#

# WorkerConfigurationRevisionDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationRevisionDescriptionTypeDef

def get_value() -> WorkerConfigurationRevisionDescriptionTypeDef:
    return {
        "creationTime": ...,
    }
# WorkerConfigurationRevisionDescriptionTypeDef definition

class WorkerConfigurationRevisionDescriptionTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    propertiesFileContent: NotRequired[str],
    revision: NotRequired[int],

FirehoseLogDeliveryDescriptionTypeDef#

# FirehoseLogDeliveryDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import FirehoseLogDeliveryDescriptionTypeDef

def get_value() -> FirehoseLogDeliveryDescriptionTypeDef:
    return {
        "deliveryStream": ...,
    }
# FirehoseLogDeliveryDescriptionTypeDef definition

class FirehoseLogDeliveryDescriptionTypeDef(TypedDict):
    deliveryStream: NotRequired[str],
    enabled: NotRequired[bool],

FirehoseLogDeliveryTypeDef#

# FirehoseLogDeliveryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import FirehoseLogDeliveryTypeDef

def get_value() -> FirehoseLogDeliveryTypeDef:
    return {
        "enabled": ...,
    }
# FirehoseLogDeliveryTypeDef definition

class FirehoseLogDeliveryTypeDef(TypedDict):
    enabled: bool,
    deliveryStream: NotRequired[str],

ListConnectorsRequestListConnectorsPaginateTypeDef#

# ListConnectorsRequestListConnectorsPaginateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListConnectorsRequestListConnectorsPaginateTypeDef

def get_value() -> ListConnectorsRequestListConnectorsPaginateTypeDef:
    return {
        "connectorNamePrefix": ...,
    }
# ListConnectorsRequestListConnectorsPaginateTypeDef definition

class ListConnectorsRequestListConnectorsPaginateTypeDef(TypedDict):
    connectorNamePrefix: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListConnectorsRequestRequestTypeDef#

# ListConnectorsRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListConnectorsRequestRequestTypeDef

def get_value() -> ListConnectorsRequestRequestTypeDef:
    return {
        "connectorNamePrefix": ...,
    }
# ListConnectorsRequestRequestTypeDef definition

class ListConnectorsRequestRequestTypeDef(TypedDict):
    connectorNamePrefix: NotRequired[str],
    maxResults: NotRequired[int],
    nextToken: NotRequired[str],

ListCustomPluginsRequestListCustomPluginsPaginateTypeDef#

# ListCustomPluginsRequestListCustomPluginsPaginateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListCustomPluginsRequestListCustomPluginsPaginateTypeDef

def get_value() -> ListCustomPluginsRequestListCustomPluginsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
# ListCustomPluginsRequestListCustomPluginsPaginateTypeDef definition

class ListCustomPluginsRequestListCustomPluginsPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListCustomPluginsRequestRequestTypeDef#

# ListCustomPluginsRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListCustomPluginsRequestRequestTypeDef

def get_value() -> ListCustomPluginsRequestRequestTypeDef:
    return {
        "maxResults": ...,
    }
# ListCustomPluginsRequestRequestTypeDef definition

class ListCustomPluginsRequestRequestTypeDef(TypedDict):
    maxResults: NotRequired[int],
    nextToken: NotRequired[str],

ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef#

# ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef

def get_value() -> ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
# ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef definition

class ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListWorkerConfigurationsRequestRequestTypeDef#

# ListWorkerConfigurationsRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsRequestRequestTypeDef

def get_value() -> ListWorkerConfigurationsRequestRequestTypeDef:
    return {
        "maxResults": ...,
    }
# ListWorkerConfigurationsRequestRequestTypeDef definition

class ListWorkerConfigurationsRequestRequestTypeDef(TypedDict):
    maxResults: NotRequired[int],
    nextToken: NotRequired[str],

PaginatorConfigTypeDef#

# PaginatorConfigTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import PaginatorConfigTypeDef

def get_value() -> PaginatorConfigTypeDef:
    return {
        "MaxItems": ...,
    }
# PaginatorConfigTypeDef definition

class PaginatorConfigTypeDef(TypedDict):
    MaxItems: NotRequired[int],
    PageSize: NotRequired[int],
    StartingToken: NotRequired[str],

ResponseMetadataTypeDef#

# ResponseMetadataTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ResponseMetadataTypeDef

def get_value() -> ResponseMetadataTypeDef:
    return {
        "RequestId": ...,
        "HostId": ...,
        "HTTPStatusCode": ...,
        "HTTPHeaders": ...,
        "RetryAttempts": ...,
    }
# ResponseMetadataTypeDef definition

class ResponseMetadataTypeDef(TypedDict):
    RequestId: str,
    HostId: str,
    HTTPStatusCode: int,
    HTTPHeaders: Dict[str, str],
    RetryAttempts: int,

S3LogDeliveryDescriptionTypeDef#

# S3LogDeliveryDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import S3LogDeliveryDescriptionTypeDef

def get_value() -> S3LogDeliveryDescriptionTypeDef:
    return {
        "bucket": ...,
    }
# S3LogDeliveryDescriptionTypeDef definition

class S3LogDeliveryDescriptionTypeDef(TypedDict):
    bucket: NotRequired[str],
    enabled: NotRequired[bool],
    prefix: NotRequired[str],

S3LogDeliveryTypeDef#

# S3LogDeliveryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import S3LogDeliveryTypeDef

def get_value() -> S3LogDeliveryTypeDef:
    return {
        "enabled": ...,
    }
# S3LogDeliveryTypeDef definition

class S3LogDeliveryTypeDef(TypedDict):
    enabled: bool,
    bucket: NotRequired[str],
    prefix: NotRequired[str],

UpdateConnectorResponseTypeDef#

# UpdateConnectorResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import UpdateConnectorResponseTypeDef

def get_value() -> UpdateConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
        "connectorState": ...,
        "ResponseMetadata": ...,
    }
# UpdateConnectorResponseTypeDef definition

class UpdateConnectorResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorState: ConnectorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorStateType
  2. See ResponseMetadataTypeDef

ApacheKafkaClusterDescriptionTypeDef#

# ApacheKafkaClusterDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ApacheKafkaClusterDescriptionTypeDef

def get_value() -> ApacheKafkaClusterDescriptionTypeDef:
    return {
        "bootstrapServers": ...,
    }
# ApacheKafkaClusterDescriptionTypeDef definition

class ApacheKafkaClusterDescriptionTypeDef(TypedDict):
    bootstrapServers: NotRequired[str],
    vpc: NotRequired[VpcDescriptionTypeDef],  # (1)
  1. See VpcDescriptionTypeDef

ApacheKafkaClusterTypeDef#

# ApacheKafkaClusterTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ApacheKafkaClusterTypeDef

def get_value() -> ApacheKafkaClusterTypeDef:
    return {
        "bootstrapServers": ...,
        "vpc": ...,
    }
# ApacheKafkaClusterTypeDef definition

class ApacheKafkaClusterTypeDef(TypedDict):
    bootstrapServers: str,
    vpc: VpcTypeDef,  # (1)
  1. See VpcTypeDef

AutoScalingDescriptionTypeDef#

# AutoScalingDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import AutoScalingDescriptionTypeDef

def get_value() -> AutoScalingDescriptionTypeDef:
    return {
        "maxWorkerCount": ...,
    }
# AutoScalingDescriptionTypeDef definition

class AutoScalingDescriptionTypeDef(TypedDict):
    maxWorkerCount: NotRequired[int],
    mcuCount: NotRequired[int],
    minWorkerCount: NotRequired[int],
    scaleInPolicy: NotRequired[ScaleInPolicyDescriptionTypeDef],  # (1)
    scaleOutPolicy: NotRequired[ScaleOutPolicyDescriptionTypeDef],  # (2)
  1. See ScaleInPolicyDescriptionTypeDef
  2. See ScaleOutPolicyDescriptionTypeDef

AutoScalingTypeDef#

# AutoScalingTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import AutoScalingTypeDef

def get_value() -> AutoScalingTypeDef:
    return {
        "maxWorkerCount": ...,
        "mcuCount": ...,
        "minWorkerCount": ...,
    }
# AutoScalingTypeDef definition

class AutoScalingTypeDef(TypedDict):
    maxWorkerCount: int,
    mcuCount: int,
    minWorkerCount: int,
    scaleInPolicy: NotRequired[ScaleInPolicyTypeDef],  # (1)
    scaleOutPolicy: NotRequired[ScaleOutPolicyTypeDef],  # (2)
  1. See ScaleInPolicyTypeDef
  2. See ScaleOutPolicyTypeDef

AutoScalingUpdateTypeDef#

# AutoScalingUpdateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import AutoScalingUpdateTypeDef

def get_value() -> AutoScalingUpdateTypeDef:
    return {
        "maxWorkerCount": ...,
        "mcuCount": ...,
        "minWorkerCount": ...,
        "scaleInPolicy": ...,
        "scaleOutPolicy": ...,
    }
# AutoScalingUpdateTypeDef definition

class AutoScalingUpdateTypeDef(TypedDict):
    maxWorkerCount: int,
    mcuCount: int,
    minWorkerCount: int,
    scaleInPolicy: ScaleInPolicyUpdateTypeDef,  # (1)
    scaleOutPolicy: ScaleOutPolicyUpdateTypeDef,  # (2)
  1. See ScaleInPolicyUpdateTypeDef
  2. See ScaleOutPolicyUpdateTypeDef

CreateWorkerConfigurationResponseTypeDef#

# CreateWorkerConfigurationResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CreateWorkerConfigurationResponseTypeDef

def get_value() -> CreateWorkerConfigurationResponseTypeDef:
    return {
        "creationTime": ...,
        "latestRevision": ...,
        "name": ...,
        "workerConfigurationArn": ...,
        "ResponseMetadata": ...,
    }
# CreateWorkerConfigurationResponseTypeDef definition

class CreateWorkerConfigurationResponseTypeDef(TypedDict):
    creationTime: datetime,
    latestRevision: WorkerConfigurationRevisionSummaryTypeDef,  # (1)
    name: str,
    workerConfigurationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See WorkerConfigurationRevisionSummaryTypeDef
  2. See ResponseMetadataTypeDef

WorkerConfigurationSummaryTypeDef#

# WorkerConfigurationSummaryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationSummaryTypeDef

def get_value() -> WorkerConfigurationSummaryTypeDef:
    return {
        "creationTime": ...,
    }
# WorkerConfigurationSummaryTypeDef definition

class WorkerConfigurationSummaryTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    latestRevision: NotRequired[WorkerConfigurationRevisionSummaryTypeDef],  # (1)
    name: NotRequired[str],
    workerConfigurationArn: NotRequired[str],
  1. See WorkerConfigurationRevisionSummaryTypeDef

PluginDescriptionTypeDef#

# PluginDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import PluginDescriptionTypeDef

def get_value() -> PluginDescriptionTypeDef:
    return {
        "customPlugin": ...,
    }
# PluginDescriptionTypeDef definition

class PluginDescriptionTypeDef(TypedDict):
    customPlugin: NotRequired[CustomPluginDescriptionTypeDef],  # (1)
  1. See CustomPluginDescriptionTypeDef

CustomPluginLocationDescriptionTypeDef#

# CustomPluginLocationDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginLocationDescriptionTypeDef

def get_value() -> CustomPluginLocationDescriptionTypeDef:
    return {
        "s3Location": ...,
    }
# CustomPluginLocationDescriptionTypeDef definition

class CustomPluginLocationDescriptionTypeDef(TypedDict):
    s3Location: NotRequired[S3LocationDescriptionTypeDef],  # (1)
  1. See S3LocationDescriptionTypeDef

CustomPluginLocationTypeDef#

# CustomPluginLocationTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginLocationTypeDef

def get_value() -> CustomPluginLocationTypeDef:
    return {
        "s3Location": ...,
    }
# CustomPluginLocationTypeDef definition

class CustomPluginLocationTypeDef(TypedDict):
    s3Location: S3LocationTypeDef,  # (1)
  1. See S3LocationTypeDef

PluginTypeDef#

# PluginTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import PluginTypeDef

def get_value() -> PluginTypeDef:
    return {
        "customPlugin": ...,
    }
# PluginTypeDef definition

class PluginTypeDef(TypedDict):
    customPlugin: CustomPluginTypeDef,  # (1)
  1. See CustomPluginTypeDef

DescribeWorkerConfigurationResponseTypeDef#

# DescribeWorkerConfigurationResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DescribeWorkerConfigurationResponseTypeDef

def get_value() -> DescribeWorkerConfigurationResponseTypeDef:
    return {
        "creationTime": ...,
        "description": ...,
        "latestRevision": ...,
        "name": ...,
        "workerConfigurationArn": ...,
        "ResponseMetadata": ...,
    }
# DescribeWorkerConfigurationResponseTypeDef definition

class DescribeWorkerConfigurationResponseTypeDef(TypedDict):
    creationTime: datetime,
    description: str,
    latestRevision: WorkerConfigurationRevisionDescriptionTypeDef,  # (1)
    name: str,
    workerConfigurationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See WorkerConfigurationRevisionDescriptionTypeDef
  2. See ResponseMetadataTypeDef

WorkerLogDeliveryDescriptionTypeDef#

# WorkerLogDeliveryDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerLogDeliveryDescriptionTypeDef

def get_value() -> WorkerLogDeliveryDescriptionTypeDef:
    return {
        "cloudWatchLogs": ...,
    }
# WorkerLogDeliveryDescriptionTypeDef definition

class WorkerLogDeliveryDescriptionTypeDef(TypedDict):
    cloudWatchLogs: NotRequired[CloudWatchLogsLogDeliveryDescriptionTypeDef],  # (1)
    firehose: NotRequired[FirehoseLogDeliveryDescriptionTypeDef],  # (2)
    s3: NotRequired[S3LogDeliveryDescriptionTypeDef],  # (3)
  1. See CloudWatchLogsLogDeliveryDescriptionTypeDef
  2. See FirehoseLogDeliveryDescriptionTypeDef
  3. See S3LogDeliveryDescriptionTypeDef

WorkerLogDeliveryTypeDef#

# WorkerLogDeliveryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import WorkerLogDeliveryTypeDef

def get_value() -> WorkerLogDeliveryTypeDef:
    return {
        "cloudWatchLogs": ...,
    }
# WorkerLogDeliveryTypeDef definition

class WorkerLogDeliveryTypeDef(TypedDict):
    cloudWatchLogs: NotRequired[CloudWatchLogsLogDeliveryTypeDef],  # (1)
    firehose: NotRequired[FirehoseLogDeliveryTypeDef],  # (2)
    s3: NotRequired[S3LogDeliveryTypeDef],  # (3)
  1. See CloudWatchLogsLogDeliveryTypeDef
  2. See FirehoseLogDeliveryTypeDef
  3. See S3LogDeliveryTypeDef

KafkaClusterDescriptionTypeDef#

# KafkaClusterDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import KafkaClusterDescriptionTypeDef

def get_value() -> KafkaClusterDescriptionTypeDef:
    return {
        "apacheKafkaCluster": ...,
    }
# KafkaClusterDescriptionTypeDef definition

class KafkaClusterDescriptionTypeDef(TypedDict):
    apacheKafkaCluster: NotRequired[ApacheKafkaClusterDescriptionTypeDef],  # (1)
  1. See ApacheKafkaClusterDescriptionTypeDef

KafkaClusterTypeDef#

# KafkaClusterTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import KafkaClusterTypeDef

def get_value() -> KafkaClusterTypeDef:
    return {
        "apacheKafkaCluster": ...,
    }
# KafkaClusterTypeDef definition

class KafkaClusterTypeDef(TypedDict):
    apacheKafkaCluster: ApacheKafkaClusterTypeDef,  # (1)
  1. See ApacheKafkaClusterTypeDef

CapacityDescriptionTypeDef#

# CapacityDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CapacityDescriptionTypeDef

def get_value() -> CapacityDescriptionTypeDef:
    return {
        "autoScaling": ...,
    }
# CapacityDescriptionTypeDef definition

class CapacityDescriptionTypeDef(TypedDict):
    autoScaling: NotRequired[AutoScalingDescriptionTypeDef],  # (1)
    provisionedCapacity: NotRequired[ProvisionedCapacityDescriptionTypeDef],  # (2)
  1. See AutoScalingDescriptionTypeDef
  2. See ProvisionedCapacityDescriptionTypeDef

CapacityTypeDef#

# CapacityTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CapacityTypeDef

def get_value() -> CapacityTypeDef:
    return {
        "autoScaling": ...,
    }
# CapacityTypeDef definition

class CapacityTypeDef(TypedDict):
    autoScaling: NotRequired[AutoScalingTypeDef],  # (1)
    provisionedCapacity: NotRequired[ProvisionedCapacityTypeDef],  # (2)
  1. See AutoScalingTypeDef
  2. See ProvisionedCapacityTypeDef

CapacityUpdateTypeDef#

# CapacityUpdateTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CapacityUpdateTypeDef

def get_value() -> CapacityUpdateTypeDef:
    return {
        "autoScaling": ...,
    }
# CapacityUpdateTypeDef definition

class CapacityUpdateTypeDef(TypedDict):
    autoScaling: NotRequired[AutoScalingUpdateTypeDef],  # (1)
    provisionedCapacity: NotRequired[ProvisionedCapacityUpdateTypeDef],  # (2)
  1. See AutoScalingUpdateTypeDef
  2. See ProvisionedCapacityUpdateTypeDef

ListWorkerConfigurationsResponseTypeDef#

# ListWorkerConfigurationsResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsResponseTypeDef

def get_value() -> ListWorkerConfigurationsResponseTypeDef:
    return {
        "nextToken": ...,
        "workerConfigurations": ...,
        "ResponseMetadata": ...,
    }
# ListWorkerConfigurationsResponseTypeDef definition

class ListWorkerConfigurationsResponseTypeDef(TypedDict):
    nextToken: str,
    workerConfigurations: List[WorkerConfigurationSummaryTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See WorkerConfigurationSummaryTypeDef
  2. See ResponseMetadataTypeDef

CustomPluginRevisionSummaryTypeDef#

# CustomPluginRevisionSummaryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginRevisionSummaryTypeDef

def get_value() -> CustomPluginRevisionSummaryTypeDef:
    return {
        "contentType": ...,
    }
# CustomPluginRevisionSummaryTypeDef definition

class CustomPluginRevisionSummaryTypeDef(TypedDict):
    contentType: NotRequired[CustomPluginContentTypeType],  # (1)
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    fileDescription: NotRequired[CustomPluginFileDescriptionTypeDef],  # (2)
    location: NotRequired[CustomPluginLocationDescriptionTypeDef],  # (3)
    revision: NotRequired[int],
  1. See CustomPluginContentTypeType
  2. See CustomPluginFileDescriptionTypeDef
  3. See CustomPluginLocationDescriptionTypeDef

CreateCustomPluginRequestRequestTypeDef#

# CreateCustomPluginRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CreateCustomPluginRequestRequestTypeDef

def get_value() -> CreateCustomPluginRequestRequestTypeDef:
    return {
        "contentType": ...,
        "location": ...,
        "name": ...,
    }
# CreateCustomPluginRequestRequestTypeDef definition

class CreateCustomPluginRequestRequestTypeDef(TypedDict):
    contentType: CustomPluginContentTypeType,  # (1)
    location: CustomPluginLocationTypeDef,  # (2)
    name: str,
    description: NotRequired[str],
  1. See CustomPluginContentTypeType
  2. See CustomPluginLocationTypeDef

LogDeliveryDescriptionTypeDef#

# LogDeliveryDescriptionTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import LogDeliveryDescriptionTypeDef

def get_value() -> LogDeliveryDescriptionTypeDef:
    return {
        "workerLogDelivery": ...,
    }
# LogDeliveryDescriptionTypeDef definition

class LogDeliveryDescriptionTypeDef(TypedDict):
    workerLogDelivery: NotRequired[WorkerLogDeliveryDescriptionTypeDef],  # (1)
  1. See WorkerLogDeliveryDescriptionTypeDef

LogDeliveryTypeDef#

# LogDeliveryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import LogDeliveryTypeDef

def get_value() -> LogDeliveryTypeDef:
    return {
        "workerLogDelivery": ...,
    }
# LogDeliveryTypeDef definition

class LogDeliveryTypeDef(TypedDict):
    workerLogDelivery: WorkerLogDeliveryTypeDef,  # (1)
  1. See WorkerLogDeliveryTypeDef

UpdateConnectorRequestRequestTypeDef#

# UpdateConnectorRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import UpdateConnectorRequestRequestTypeDef

def get_value() -> UpdateConnectorRequestRequestTypeDef:
    return {
        "capacity": ...,
        "connectorArn": ...,
        "currentVersion": ...,
    }
# UpdateConnectorRequestRequestTypeDef definition

class UpdateConnectorRequestRequestTypeDef(TypedDict):
    capacity: CapacityUpdateTypeDef,  # (1)
    connectorArn: str,
    currentVersion: str,
  1. See CapacityUpdateTypeDef

CustomPluginSummaryTypeDef#

# CustomPluginSummaryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CustomPluginSummaryTypeDef

def get_value() -> CustomPluginSummaryTypeDef:
    return {
        "creationTime": ...,
    }
# CustomPluginSummaryTypeDef definition

class CustomPluginSummaryTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    customPluginArn: NotRequired[str],
    customPluginState: NotRequired[CustomPluginStateType],  # (1)
    description: NotRequired[str],
    latestRevision: NotRequired[CustomPluginRevisionSummaryTypeDef],  # (2)
    name: NotRequired[str],
  1. See CustomPluginStateType
  2. See CustomPluginRevisionSummaryTypeDef

DescribeCustomPluginResponseTypeDef#

# DescribeCustomPluginResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DescribeCustomPluginResponseTypeDef

def get_value() -> DescribeCustomPluginResponseTypeDef:
    return {
        "creationTime": ...,
        "customPluginArn": ...,
        "customPluginState": ...,
        "description": ...,
        "latestRevision": ...,
        "name": ...,
        "stateDescription": ...,
        "ResponseMetadata": ...,
    }
# DescribeCustomPluginResponseTypeDef definition

class DescribeCustomPluginResponseTypeDef(TypedDict):
    creationTime: datetime,
    customPluginArn: str,
    customPluginState: CustomPluginStateType,  # (1)
    description: str,
    latestRevision: CustomPluginRevisionSummaryTypeDef,  # (2)
    name: str,
    stateDescription: StateDescriptionTypeDef,  # (3)
    ResponseMetadata: ResponseMetadataTypeDef,  # (4)
  1. See CustomPluginStateType
  2. See CustomPluginRevisionSummaryTypeDef
  3. See StateDescriptionTypeDef
  4. See ResponseMetadataTypeDef

ConnectorSummaryTypeDef#

# ConnectorSummaryTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ConnectorSummaryTypeDef

def get_value() -> ConnectorSummaryTypeDef:
    return {
        "capacity": ...,
    }
# ConnectorSummaryTypeDef definition

class ConnectorSummaryTypeDef(TypedDict):
    capacity: NotRequired[CapacityDescriptionTypeDef],  # (1)
    connectorArn: NotRequired[str],
    connectorDescription: NotRequired[str],
    connectorName: NotRequired[str],
    connectorState: NotRequired[ConnectorStateType],  # (2)
    creationTime: NotRequired[datetime],
    currentVersion: NotRequired[str],
    kafkaCluster: NotRequired[KafkaClusterDescriptionTypeDef],  # (3)
    kafkaClusterClientAuthentication: NotRequired[KafkaClusterClientAuthenticationDescriptionTypeDef],  # (4)
    kafkaClusterEncryptionInTransit: NotRequired[KafkaClusterEncryptionInTransitDescriptionTypeDef],  # (5)
    kafkaConnectVersion: NotRequired[str],
    logDelivery: NotRequired[LogDeliveryDescriptionTypeDef],  # (6)
    plugins: NotRequired[List[PluginDescriptionTypeDef]],  # (7)
    serviceExecutionRoleArn: NotRequired[str],
    workerConfiguration: NotRequired[WorkerConfigurationDescriptionTypeDef],  # (8)
  1. See CapacityDescriptionTypeDef
  2. See ConnectorStateType
  3. See KafkaClusterDescriptionTypeDef
  4. See KafkaClusterClientAuthenticationDescriptionTypeDef
  5. See KafkaClusterEncryptionInTransitDescriptionTypeDef
  6. See LogDeliveryDescriptionTypeDef
  7. See PluginDescriptionTypeDef
  8. See WorkerConfigurationDescriptionTypeDef

DescribeConnectorResponseTypeDef#

# DescribeConnectorResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import DescribeConnectorResponseTypeDef

def get_value() -> DescribeConnectorResponseTypeDef:
    return {
        "capacity": ...,
        "connectorArn": ...,
        "connectorConfiguration": ...,
        "connectorDescription": ...,
        "connectorName": ...,
        "connectorState": ...,
        "creationTime": ...,
        "currentVersion": ...,
        "kafkaCluster": ...,
        "kafkaClusterClientAuthentication": ...,
        "kafkaClusterEncryptionInTransit": ...,
        "kafkaConnectVersion": ...,
        "logDelivery": ...,
        "plugins": ...,
        "serviceExecutionRoleArn": ...,
        "stateDescription": ...,
        "workerConfiguration": ...,
        "ResponseMetadata": ...,
    }
# DescribeConnectorResponseTypeDef definition

class DescribeConnectorResponseTypeDef(TypedDict):
    capacity: CapacityDescriptionTypeDef,  # (1)
    connectorArn: str,
    connectorConfiguration: Dict[str, str],
    connectorDescription: str,
    connectorName: str,
    connectorState: ConnectorStateType,  # (2)
    creationTime: datetime,
    currentVersion: str,
    kafkaCluster: KafkaClusterDescriptionTypeDef,  # (3)
    kafkaClusterClientAuthentication: KafkaClusterClientAuthenticationDescriptionTypeDef,  # (4)
    kafkaClusterEncryptionInTransit: KafkaClusterEncryptionInTransitDescriptionTypeDef,  # (5)
    kafkaConnectVersion: str,
    logDelivery: LogDeliveryDescriptionTypeDef,  # (6)
    plugins: List[PluginDescriptionTypeDef],  # (7)
    serviceExecutionRoleArn: str,
    stateDescription: StateDescriptionTypeDef,  # (8)
    workerConfiguration: WorkerConfigurationDescriptionTypeDef,  # (9)
    ResponseMetadata: ResponseMetadataTypeDef,  # (10)
  1. See CapacityDescriptionTypeDef
  2. See ConnectorStateType
  3. See KafkaClusterDescriptionTypeDef
  4. See KafkaClusterClientAuthenticationDescriptionTypeDef
  5. See KafkaClusterEncryptionInTransitDescriptionTypeDef
  6. See LogDeliveryDescriptionTypeDef
  7. See PluginDescriptionTypeDef
  8. See StateDescriptionTypeDef
  9. See WorkerConfigurationDescriptionTypeDef
  10. See ResponseMetadataTypeDef

CreateConnectorRequestRequestTypeDef#

# CreateConnectorRequestRequestTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import CreateConnectorRequestRequestTypeDef

def get_value() -> CreateConnectorRequestRequestTypeDef:
    return {
        "capacity": ...,
        "connectorConfiguration": ...,
        "connectorName": ...,
        "kafkaCluster": ...,
        "kafkaClusterClientAuthentication": ...,
        "kafkaClusterEncryptionInTransit": ...,
        "kafkaConnectVersion": ...,
        "plugins": ...,
        "serviceExecutionRoleArn": ...,
    }
# CreateConnectorRequestRequestTypeDef definition

class CreateConnectorRequestRequestTypeDef(TypedDict):
    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: NotRequired[str],
    logDelivery: NotRequired[LogDeliveryTypeDef],  # (6)
    workerConfiguration: NotRequired[WorkerConfigurationTypeDef],  # (7)
  1. See CapacityTypeDef
  2. See KafkaClusterTypeDef
  3. See KafkaClusterClientAuthenticationTypeDef
  4. See KafkaClusterEncryptionInTransitTypeDef
  5. See PluginTypeDef
  6. See LogDeliveryTypeDef
  7. See WorkerConfigurationTypeDef

ListCustomPluginsResponseTypeDef#

# ListCustomPluginsResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListCustomPluginsResponseTypeDef

def get_value() -> ListCustomPluginsResponseTypeDef:
    return {
        "customPlugins": ...,
        "nextToken": ...,
        "ResponseMetadata": ...,
    }
# ListCustomPluginsResponseTypeDef definition

class ListCustomPluginsResponseTypeDef(TypedDict):
    customPlugins: List[CustomPluginSummaryTypeDef],  # (1)
    nextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CustomPluginSummaryTypeDef
  2. See ResponseMetadataTypeDef

ListConnectorsResponseTypeDef#

# ListConnectorsResponseTypeDef usage example

from mypy_boto3_kafkaconnect.type_defs import ListConnectorsResponseTypeDef

def get_value() -> ListConnectorsResponseTypeDef:
    return {
        "connectors": ...,
        "nextToken": ...,
        "ResponseMetadata": ...,
    }
# ListConnectorsResponseTypeDef definition

class ListConnectorsResponseTypeDef(TypedDict):
    connectors: List[ConnectorSummaryTypeDef],  # (1)
    nextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorSummaryTypeDef
  2. See ResponseMetadataTypeDef