Type definitions

Index > KafkaConnect > Type definitions

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

VpcDescriptionTypeDef

# VpcDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import VpcTypeDef


def get_value() -> VpcTypeDef:
    return {
        "securityGroups": ...,
    }


# VpcTypeDef definition

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

ScaleInPolicyDescriptionTypeDef

# ScaleInPolicyDescriptionTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ScaleInPolicyDescriptionTypeDef


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


# ScaleInPolicyDescriptionTypeDef definition

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

ScaleOutPolicyDescriptionTypeDef

# ScaleOutPolicyDescriptionTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ScaleOutPolicyDescriptionTypeDef


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


# ScaleOutPolicyDescriptionTypeDef definition

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

ScaleInPolicyTypeDef

# ScaleInPolicyTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ScaleInPolicyTypeDef


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


# ScaleInPolicyTypeDef definition

class ScaleInPolicyTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleOutPolicyTypeDef

# ScaleOutPolicyTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ScaleOutPolicyTypeDef


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


# ScaleOutPolicyTypeDef definition

class ScaleOutPolicyTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleInPolicyUpdateTypeDef

# ScaleInPolicyUpdateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ScaleInPolicyUpdateTypeDef


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


# ScaleInPolicyUpdateTypeDef definition

class ScaleInPolicyUpdateTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleOutPolicyUpdateTypeDef

# ScaleOutPolicyUpdateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ScaleOutPolicyUpdateTypeDef


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


# ScaleOutPolicyUpdateTypeDef definition

class ScaleOutPolicyUpdateTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ProvisionedCapacityDescriptionTypeDef

# ProvisionedCapacityDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ProvisionedCapacityTypeDef


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


# ProvisionedCapacityTypeDef definition

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

ProvisionedCapacityUpdateTypeDef

# ProvisionedCapacityUpdateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ProvisionedCapacityUpdateTypeDef


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


# ProvisionedCapacityUpdateTypeDef definition

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

CloudWatchLogsLogDeliveryDescriptionTypeDef

# CloudWatchLogsLogDeliveryDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryTypeDef


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


# CloudWatchLogsLogDeliveryTypeDef definition

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

ConnectorOperationStepTypeDef

# ConnectorOperationStepTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ConnectorOperationStepTypeDef


def get_value() -> ConnectorOperationStepTypeDef:
    return {
        "stepType": ...,
    }


# ConnectorOperationStepTypeDef definition

class ConnectorOperationStepTypeDef(TypedDict):
    stepType: NotRequired[ConnectorOperationStepTypeType],  # (1)
    stepState: NotRequired[ConnectorOperationStepStateType],  # (2)

1. See ConnectorOperationStepTypeType
2. See ConnectorOperationStepStateType

ConnectorOperationSummaryTypeDef

# ConnectorOperationSummaryTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ConnectorOperationSummaryTypeDef


def get_value() -> ConnectorOperationSummaryTypeDef:
    return {
        "connectorOperationArn": ...,
    }


# ConnectorOperationSummaryTypeDef definition

class ConnectorOperationSummaryTypeDef(TypedDict):
    connectorOperationArn: NotRequired[str],
    connectorOperationType: NotRequired[ConnectorOperationTypeType],  # (1)
    connectorOperationState: NotRequired[ConnectorOperationStateType],  # (2)
    creationTime: NotRequired[datetime.datetime],
    endTime: NotRequired[datetime.datetime],

1. See ConnectorOperationTypeType
2. See ConnectorOperationStateType

KafkaClusterClientAuthenticationDescriptionTypeDef

# KafkaClusterClientAuthenticationDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import WorkerConfigurationTypeDef


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


# WorkerConfigurationTypeDef definition

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

ResponseMetadataTypeDef

# ResponseMetadataTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ResponseMetadataTypeDef


def get_value() -> ResponseMetadataTypeDef:
    return {
        "RequestId": ...,
    }


# ResponseMetadataTypeDef definition

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

CreateWorkerConfigurationRequestTypeDef

# CreateWorkerConfigurationRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CreateWorkerConfigurationRequestTypeDef


def get_value() -> CreateWorkerConfigurationRequestTypeDef:
    return {
        "name": ...,
    }


# CreateWorkerConfigurationRequestTypeDef definition

class CreateWorkerConfigurationRequestTypeDef(TypedDict):
    name: str,
    propertiesFileContent: str,
    description: NotRequired[str],
    tags: NotRequired[Mapping[str, str]],

WorkerConfigurationRevisionSummaryTypeDef

# WorkerConfigurationRevisionSummaryTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import WorkerConfigurationRevisionSummaryTypeDef


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


# WorkerConfigurationRevisionSummaryTypeDef definition

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

CustomPluginDescriptionTypeDef

# CustomPluginDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import S3LocationTypeDef


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


# S3LocationTypeDef definition

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

CustomPluginTypeDef

# CustomPluginTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CustomPluginTypeDef


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


# CustomPluginTypeDef definition

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

DeleteConnectorRequestTypeDef

# DeleteConnectorRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DeleteConnectorRequestTypeDef


def get_value() -> DeleteConnectorRequestTypeDef:
    return {
        "connectorArn": ...,
    }


# DeleteConnectorRequestTypeDef definition

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

DeleteCustomPluginRequestTypeDef

# DeleteCustomPluginRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DeleteCustomPluginRequestTypeDef


def get_value() -> DeleteCustomPluginRequestTypeDef:
    return {
        "customPluginArn": ...,
    }


# DeleteCustomPluginRequestTypeDef definition

class DeleteCustomPluginRequestTypeDef(TypedDict):
    customPluginArn: str,

DeleteWorkerConfigurationRequestTypeDef

# DeleteWorkerConfigurationRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DeleteWorkerConfigurationRequestTypeDef


def get_value() -> DeleteWorkerConfigurationRequestTypeDef:
    return {
        "workerConfigurationArn": ...,
    }


# DeleteWorkerConfigurationRequestTypeDef definition

class DeleteWorkerConfigurationRequestTypeDef(TypedDict):
    workerConfigurationArn: str,

DescribeConnectorOperationRequestTypeDef

# DescribeConnectorOperationRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeConnectorOperationRequestTypeDef


def get_value() -> DescribeConnectorOperationRequestTypeDef:
    return {
        "connectorOperationArn": ...,
    }


# DescribeConnectorOperationRequestTypeDef definition

class DescribeConnectorOperationRequestTypeDef(TypedDict):
    connectorOperationArn: str,

StateDescriptionTypeDef

# StateDescriptionTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import StateDescriptionTypeDef


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


# StateDescriptionTypeDef definition

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

DescribeConnectorRequestTypeDef

# DescribeConnectorRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeConnectorRequestTypeDef


def get_value() -> DescribeConnectorRequestTypeDef:
    return {
        "connectorArn": ...,
    }


# DescribeConnectorRequestTypeDef definition

class DescribeConnectorRequestTypeDef(TypedDict):
    connectorArn: str,

DescribeCustomPluginRequestTypeDef

# DescribeCustomPluginRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeCustomPluginRequestTypeDef


def get_value() -> DescribeCustomPluginRequestTypeDef:
    return {
        "customPluginArn": ...,
    }


# DescribeCustomPluginRequestTypeDef definition

class DescribeCustomPluginRequestTypeDef(TypedDict):
    customPluginArn: str,

DescribeWorkerConfigurationRequestTypeDef

# DescribeWorkerConfigurationRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeWorkerConfigurationRequestTypeDef


def get_value() -> DescribeWorkerConfigurationRequestTypeDef:
    return {
        "workerConfigurationArn": ...,
    }


# DescribeWorkerConfigurationRequestTypeDef definition

class DescribeWorkerConfigurationRequestTypeDef(TypedDict):
    workerConfigurationArn: str,

WorkerConfigurationRevisionDescriptionTypeDef

# WorkerConfigurationRevisionDescriptionTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import WorkerConfigurationRevisionDescriptionTypeDef


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


# WorkerConfigurationRevisionDescriptionTypeDef definition

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

FirehoseLogDeliveryDescriptionTypeDef

# FirehoseLogDeliveryDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import FirehoseLogDeliveryTypeDef


def get_value() -> FirehoseLogDeliveryTypeDef:
    return {
        "deliveryStream": ...,
    }


# FirehoseLogDeliveryTypeDef definition

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

PaginatorConfigTypeDef

# PaginatorConfigTypeDef TypedDict usage example

from types_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],

ListConnectorOperationsRequestTypeDef

# ListConnectorOperationsRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListConnectorOperationsRequestTypeDef


def get_value() -> ListConnectorOperationsRequestTypeDef:
    return {
        "connectorArn": ...,
    }


# ListConnectorOperationsRequestTypeDef definition

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

ListConnectorsRequestTypeDef

# ListConnectorsRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListConnectorsRequestTypeDef


def get_value() -> ListConnectorsRequestTypeDef:
    return {
        "connectorNamePrefix": ...,
    }


# ListConnectorsRequestTypeDef definition

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

ListCustomPluginsRequestTypeDef

# ListCustomPluginsRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListCustomPluginsRequestTypeDef


def get_value() -> ListCustomPluginsRequestTypeDef:
    return {
        "maxResults": ...,
    }


# ListCustomPluginsRequestTypeDef definition

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

ListTagsForResourceRequestTypeDef

# ListTagsForResourceRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListTagsForResourceRequestTypeDef


def get_value() -> ListTagsForResourceRequestTypeDef:
    return {
        "resourceArn": ...,
    }


# ListTagsForResourceRequestTypeDef definition

class ListTagsForResourceRequestTypeDef(TypedDict):
    resourceArn: str,

ListWorkerConfigurationsRequestTypeDef

# ListWorkerConfigurationsRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsRequestTypeDef


def get_value() -> ListWorkerConfigurationsRequestTypeDef:
    return {
        "maxResults": ...,
    }


# ListWorkerConfigurationsRequestTypeDef definition

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

S3LogDeliveryDescriptionTypeDef

# S3LogDeliveryDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import S3LogDeliveryTypeDef


def get_value() -> S3LogDeliveryTypeDef:
    return {
        "bucket": ...,
    }


# S3LogDeliveryTypeDef definition

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

TagResourceRequestTypeDef

# TagResourceRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import TagResourceRequestTypeDef


def get_value() -> TagResourceRequestTypeDef:
    return {
        "resourceArn": ...,
    }


# TagResourceRequestTypeDef definition

class TagResourceRequestTypeDef(TypedDict):
    resourceArn: str,
    tags: Mapping[str, str],

UntagResourceRequestTypeDef

# UntagResourceRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import UntagResourceRequestTypeDef


def get_value() -> UntagResourceRequestTypeDef:
    return {
        "resourceArn": ...,
    }


# UntagResourceRequestTypeDef definition

class UntagResourceRequestTypeDef(TypedDict):
    resourceArn: str,
    tagKeys: Sequence[str],

ApacheKafkaClusterDescriptionTypeDef

# ApacheKafkaClusterDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ApacheKafkaClusterTypeDef


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


# ApacheKafkaClusterTypeDef definition

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

1. See VpcTypeDef

AutoScalingDescriptionTypeDef

# AutoScalingDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import AutoScalingTypeDef


def get_value() -> AutoScalingTypeDef:
    return {
        "maxWorkerCount": ...,
    }


# 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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import AutoScalingUpdateTypeDef


def get_value() -> AutoScalingUpdateTypeDef:
    return {
        "maxWorkerCount": ...,
    }


# AutoScalingUpdateTypeDef definition

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

1. See ScaleInPolicyUpdateTypeDef
2. See ScaleOutPolicyUpdateTypeDef

CreateConnectorResponseTypeDef

# CreateConnectorResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CreateConnectorResponseTypeDef


def get_value() -> CreateConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
    }


# CreateConnectorResponseTypeDef definition

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

1. See ConnectorStateType
2. See ResponseMetadataTypeDef

CreateCustomPluginResponseTypeDef

# CreateCustomPluginResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CreateCustomPluginResponseTypeDef


def get_value() -> CreateCustomPluginResponseTypeDef:
    return {
        "customPluginArn": ...,
    }


# CreateCustomPluginResponseTypeDef definition

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

1. See CustomPluginStateType
2. See ResponseMetadataTypeDef

DeleteConnectorResponseTypeDef

# DeleteConnectorResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DeleteConnectorResponseTypeDef


def get_value() -> DeleteConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
    }


# DeleteConnectorResponseTypeDef definition

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

1. See ConnectorStateType
2. See ResponseMetadataTypeDef

DeleteCustomPluginResponseTypeDef

# DeleteCustomPluginResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DeleteCustomPluginResponseTypeDef


def get_value() -> DeleteCustomPluginResponseTypeDef:
    return {
        "customPluginArn": ...,
    }


# DeleteCustomPluginResponseTypeDef definition

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

1. See CustomPluginStateType
2. See ResponseMetadataTypeDef

DeleteWorkerConfigurationResponseTypeDef

# DeleteWorkerConfigurationResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DeleteWorkerConfigurationResponseTypeDef


def get_value() -> DeleteWorkerConfigurationResponseTypeDef:
    return {
        "workerConfigurationArn": ...,
    }


# DeleteWorkerConfigurationResponseTypeDef definition

class DeleteWorkerConfigurationResponseTypeDef(TypedDict):
    workerConfigurationArn: str,
    workerConfigurationState: WorkerConfigurationStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)

1. See WorkerConfigurationStateType
2. See ResponseMetadataTypeDef

ListConnectorOperationsResponseTypeDef

# ListConnectorOperationsResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListConnectorOperationsResponseTypeDef


def get_value() -> ListConnectorOperationsResponseTypeDef:
    return {
        "connectorOperations": ...,
    }


# ListConnectorOperationsResponseTypeDef definition

class ListConnectorOperationsResponseTypeDef(TypedDict):
    connectorOperations: List[ConnectorOperationSummaryTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    nextToken: NotRequired[str],

1. See List[ConnectorOperationSummaryTypeDef]
2. See ResponseMetadataTypeDef

ListTagsForResourceResponseTypeDef

# ListTagsForResourceResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListTagsForResourceResponseTypeDef


def get_value() -> ListTagsForResourceResponseTypeDef:
    return {
        "tags": ...,
    }


# ListTagsForResourceResponseTypeDef definition

class ListTagsForResourceResponseTypeDef(TypedDict):
    tags: Dict[str, str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)

1. See ResponseMetadataTypeDef

UpdateConnectorResponseTypeDef

# UpdateConnectorResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import UpdateConnectorResponseTypeDef


def get_value() -> UpdateConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
    }


# UpdateConnectorResponseTypeDef definition

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

1. See ConnectorStateType
2. See ResponseMetadataTypeDef

CreateWorkerConfigurationResponseTypeDef

# CreateWorkerConfigurationResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CreateWorkerConfigurationResponseTypeDef


def get_value() -> CreateWorkerConfigurationResponseTypeDef:
    return {
        "creationTime": ...,
    }


# CreateWorkerConfigurationResponseTypeDef definition

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

1. See WorkerConfigurationRevisionSummaryTypeDef
2. See WorkerConfigurationStateType
3. See ResponseMetadataTypeDef

WorkerConfigurationSummaryTypeDef

# WorkerConfigurationSummaryTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import WorkerConfigurationSummaryTypeDef


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


# WorkerConfigurationSummaryTypeDef definition

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

1. See WorkerConfigurationRevisionSummaryTypeDef
2. See WorkerConfigurationStateType

PluginDescriptionTypeDef

# PluginDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeWorkerConfigurationResponseTypeDef


def get_value() -> DescribeWorkerConfigurationResponseTypeDef:
    return {
        "creationTime": ...,
    }


# DescribeWorkerConfigurationResponseTypeDef definition

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

1. See WorkerConfigurationRevisionDescriptionTypeDef
2. See WorkerConfigurationStateType
3. See ResponseMetadataTypeDef

ListConnectorOperationsRequestPaginateTypeDef

# ListConnectorOperationsRequestPaginateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListConnectorOperationsRequestPaginateTypeDef


def get_value() -> ListConnectorOperationsRequestPaginateTypeDef:
    return {
        "connectorArn": ...,
    }


# ListConnectorOperationsRequestPaginateTypeDef definition

class ListConnectorOperationsRequestPaginateTypeDef(TypedDict):
    connectorArn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

ListConnectorsRequestPaginateTypeDef

# ListConnectorsRequestPaginateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListConnectorsRequestPaginateTypeDef


def get_value() -> ListConnectorsRequestPaginateTypeDef:
    return {
        "connectorNamePrefix": ...,
    }


# ListConnectorsRequestPaginateTypeDef definition

class ListConnectorsRequestPaginateTypeDef(TypedDict):
    connectorNamePrefix: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

ListCustomPluginsRequestPaginateTypeDef

# ListCustomPluginsRequestPaginateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListCustomPluginsRequestPaginateTypeDef


def get_value() -> ListCustomPluginsRequestPaginateTypeDef:
    return {
        "namePrefix": ...,
    }


# ListCustomPluginsRequestPaginateTypeDef definition

class ListCustomPluginsRequestPaginateTypeDef(TypedDict):
    namePrefix: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

ListWorkerConfigurationsRequestPaginateTypeDef

# ListWorkerConfigurationsRequestPaginateTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsRequestPaginateTypeDef


def get_value() -> ListWorkerConfigurationsRequestPaginateTypeDef:
    return {
        "namePrefix": ...,
    }


# ListWorkerConfigurationsRequestPaginateTypeDef definition

class ListWorkerConfigurationsRequestPaginateTypeDef(TypedDict):
    namePrefix: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)

1. See PaginatorConfigTypeDef

WorkerLogDeliveryDescriptionTypeDef

# WorkerLogDeliveryDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsResponseTypeDef


def get_value() -> ListWorkerConfigurationsResponseTypeDef:
    return {
        "nextToken": ...,
    }


# ListWorkerConfigurationsResponseTypeDef definition

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

1. See List[WorkerConfigurationSummaryTypeDef]
2. See ResponseMetadataTypeDef

CustomPluginRevisionSummaryTypeDef

# CustomPluginRevisionSummaryTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CustomPluginRevisionSummaryTypeDef


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


# CustomPluginRevisionSummaryTypeDef definition

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

1. See CustomPluginContentTypeType
2. See CustomPluginFileDescriptionTypeDef
3. See CustomPluginLocationDescriptionTypeDef

CreateCustomPluginRequestTypeDef

# CreateCustomPluginRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CreateCustomPluginRequestTypeDef


def get_value() -> CreateCustomPluginRequestTypeDef:
    return {
        "contentType": ...,
    }


# CreateCustomPluginRequestTypeDef definition

class CreateCustomPluginRequestTypeDef(TypedDict):
    contentType: CustomPluginContentTypeType,  # (1)
    location: CustomPluginLocationTypeDef,  # (2)
    name: str,
    description: NotRequired[str],
    tags: NotRequired[Mapping[str, str]],

1. See CustomPluginContentTypeType
2. See CustomPluginLocationTypeDef

LogDeliveryDescriptionTypeDef

# LogDeliveryDescriptionTypeDef TypedDict usage example

from types_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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import LogDeliveryTypeDef


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


# LogDeliveryTypeDef definition

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

1. See WorkerLogDeliveryTypeDef

WorkerSettingTypeDef

# WorkerSettingTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import WorkerSettingTypeDef


def get_value() -> WorkerSettingTypeDef:
    return {
        "capacity": ...,
    }


# WorkerSettingTypeDef definition

class WorkerSettingTypeDef(TypedDict):
    capacity: NotRequired[CapacityDescriptionTypeDef],  # (1)

1. See CapacityDescriptionTypeDef

UpdateConnectorRequestTypeDef

# UpdateConnectorRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import UpdateConnectorRequestTypeDef


def get_value() -> UpdateConnectorRequestTypeDef:
    return {
        "connectorArn": ...,
    }


# UpdateConnectorRequestTypeDef definition

class UpdateConnectorRequestTypeDef(TypedDict):
    connectorArn: str,
    currentVersion: str,
    capacity: NotRequired[CapacityUpdateTypeDef],  # (1)
    connectorConfiguration: NotRequired[Mapping[str, str]],

1. See CapacityUpdateTypeDef

CustomPluginSummaryTypeDef

# CustomPluginSummaryTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CustomPluginSummaryTypeDef


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


# CustomPluginSummaryTypeDef definition

class CustomPluginSummaryTypeDef(TypedDict):
    creationTime: NotRequired[datetime.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 TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeCustomPluginResponseTypeDef


def get_value() -> DescribeCustomPluginResponseTypeDef:
    return {
        "creationTime": ...,
    }


# DescribeCustomPluginResponseTypeDef definition

class DescribeCustomPluginResponseTypeDef(TypedDict):
    creationTime: datetime.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 TypedDict usage example

from types_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.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 List[PluginDescriptionTypeDef]
8. See WorkerConfigurationDescriptionTypeDef

DescribeConnectorResponseTypeDef

# DescribeConnectorResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeConnectorResponseTypeDef


def get_value() -> DescribeConnectorResponseTypeDef:
    return {
        "capacity": ...,
    }


# DescribeConnectorResponseTypeDef definition

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

1. See CapacityDescriptionTypeDef
2. See ConnectorStateType
3. See KafkaClusterDescriptionTypeDef
4. See KafkaClusterClientAuthenticationDescriptionTypeDef
5. See KafkaClusterEncryptionInTransitDescriptionTypeDef
6. See LogDeliveryDescriptionTypeDef
7. See List[PluginDescriptionTypeDef]
8. See WorkerConfigurationDescriptionTypeDef
9. See StateDescriptionTypeDef
10. See ResponseMetadataTypeDef

CreateConnectorRequestTypeDef

# CreateConnectorRequestTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import CreateConnectorRequestTypeDef


def get_value() -> CreateConnectorRequestTypeDef:
    return {
        "capacity": ...,
    }


# CreateConnectorRequestTypeDef definition

class CreateConnectorRequestTypeDef(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)
    tags: NotRequired[Mapping[str, str]],

1. See CapacityTypeDef
2. See KafkaClusterTypeDef
3. See KafkaClusterClientAuthenticationTypeDef
4. See KafkaClusterEncryptionInTransitTypeDef
5. See Sequence[PluginTypeDef]
6. See LogDeliveryTypeDef
7. See WorkerConfigurationTypeDef

DescribeConnectorOperationResponseTypeDef

# DescribeConnectorOperationResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import DescribeConnectorOperationResponseTypeDef


def get_value() -> DescribeConnectorOperationResponseTypeDef:
    return {
        "connectorArn": ...,
    }


# DescribeConnectorOperationResponseTypeDef definition

class DescribeConnectorOperationResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorOperationArn: str,
    connectorOperationState: ConnectorOperationStateType,  # (1)
    connectorOperationType: ConnectorOperationTypeType,  # (2)
    operationSteps: List[ConnectorOperationStepTypeDef],  # (3)
    originWorkerSetting: WorkerSettingTypeDef,  # (4)
    originConnectorConfiguration: Dict[str, str],
    targetWorkerSetting: WorkerSettingTypeDef,  # (4)
    targetConnectorConfiguration: Dict[str, str],
    errorInfo: StateDescriptionTypeDef,  # (6)
    creationTime: datetime.datetime,
    endTime: datetime.datetime,
    ResponseMetadata: ResponseMetadataTypeDef,  # (7)

1. See ConnectorOperationStateType
2. See ConnectorOperationTypeType
3. See List[ConnectorOperationStepTypeDef]
4. See WorkerSettingTypeDef
5. See WorkerSettingTypeDef
6. See StateDescriptionTypeDef
7. See ResponseMetadataTypeDef

ListCustomPluginsResponseTypeDef

# ListCustomPluginsResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListCustomPluginsResponseTypeDef


def get_value() -> ListCustomPluginsResponseTypeDef:
    return {
        "customPlugins": ...,
    }


# ListCustomPluginsResponseTypeDef definition

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

1. See List[CustomPluginSummaryTypeDef]
2. See ResponseMetadataTypeDef

ListConnectorsResponseTypeDef

# ListConnectorsResponseTypeDef TypedDict usage example

from types_boto3_kafkaconnect.type_defs import ListConnectorsResponseTypeDef


def get_value() -> ListConnectorsResponseTypeDef:
    return {
        "connectors": ...,
    }


# ListConnectorsResponseTypeDef definition

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

1. See List[ConnectorSummaryTypeDef]
2. See ResponseMetadataTypeDef