Skip to content

Typed dictionaries

Index > KafkaConnect > Typed dictionaries

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

VpcDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import VpcDescriptionTypeDef

def get_value() -> VpcDescriptionTypeDef:
    return {
        "securityGroups": ...,
    }
Definition
class VpcDescriptionTypeDef(TypedDict):
    securityGroups: NotRequired[List[str]],
    subnets: NotRequired[List[str]],

VpcTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import VpcTypeDef

def get_value() -> VpcTypeDef:
    return {
        "subnets": ...,
    }
Definition
class VpcTypeDef(TypedDict):
    subnets: Sequence[str],
    securityGroups: NotRequired[Sequence[str]],

ScaleInPolicyDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ScaleInPolicyDescriptionTypeDef

def get_value() -> ScaleInPolicyDescriptionTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
Definition
class ScaleInPolicyDescriptionTypeDef(TypedDict):
    cpuUtilizationPercentage: NotRequired[int],

ScaleOutPolicyDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ScaleOutPolicyDescriptionTypeDef

def get_value() -> ScaleOutPolicyDescriptionTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
Definition
class ScaleOutPolicyDescriptionTypeDef(TypedDict):
    cpuUtilizationPercentage: NotRequired[int],

ScaleInPolicyTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ScaleInPolicyTypeDef

def get_value() -> ScaleInPolicyTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
Definition
class ScaleInPolicyTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleOutPolicyTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ScaleOutPolicyTypeDef

def get_value() -> ScaleOutPolicyTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
Definition
class ScaleOutPolicyTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleInPolicyUpdateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ScaleInPolicyUpdateTypeDef

def get_value() -> ScaleInPolicyUpdateTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
Definition
class ScaleInPolicyUpdateTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ScaleOutPolicyUpdateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ScaleOutPolicyUpdateTypeDef

def get_value() -> ScaleOutPolicyUpdateTypeDef:
    return {
        "cpuUtilizationPercentage": ...,
    }
Definition
class ScaleOutPolicyUpdateTypeDef(TypedDict):
    cpuUtilizationPercentage: int,

ProvisionedCapacityDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ProvisionedCapacityDescriptionTypeDef

def get_value() -> ProvisionedCapacityDescriptionTypeDef:
    return {
        "mcuCount": ...,
    }
Definition
class ProvisionedCapacityDescriptionTypeDef(TypedDict):
    mcuCount: NotRequired[int],
    workerCount: NotRequired[int],

ProvisionedCapacityTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ProvisionedCapacityTypeDef

def get_value() -> ProvisionedCapacityTypeDef:
    return {
        "mcuCount": ...,
        "workerCount": ...,
    }
Definition
class ProvisionedCapacityTypeDef(TypedDict):
    mcuCount: int,
    workerCount: int,

ProvisionedCapacityUpdateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ProvisionedCapacityUpdateTypeDef

def get_value() -> ProvisionedCapacityUpdateTypeDef:
    return {
        "mcuCount": ...,
        "workerCount": ...,
    }
Definition
class ProvisionedCapacityUpdateTypeDef(TypedDict):
    mcuCount: int,
    workerCount: int,

CloudWatchLogsLogDeliveryDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryDescriptionTypeDef

def get_value() -> CloudWatchLogsLogDeliveryDescriptionTypeDef:
    return {
        "enabled": ...,
    }
Definition
class CloudWatchLogsLogDeliveryDescriptionTypeDef(TypedDict):
    enabled: NotRequired[bool],
    logGroup: NotRequired[str],

CloudWatchLogsLogDeliveryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryTypeDef

def get_value() -> CloudWatchLogsLogDeliveryTypeDef:
    return {
        "enabled": ...,
    }
Definition
class CloudWatchLogsLogDeliveryTypeDef(TypedDict):
    enabled: bool,
    logGroup: NotRequired[str],

KafkaClusterClientAuthenticationDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import KafkaClusterClientAuthenticationDescriptionTypeDef

def get_value() -> KafkaClusterClientAuthenticationDescriptionTypeDef:
    return {
        "authenticationType": ...,
    }
Definition
class KafkaClusterClientAuthenticationDescriptionTypeDef(TypedDict):
    authenticationType: NotRequired[KafkaClusterClientAuthenticationTypeType],  # (1)
  1. See KafkaClusterClientAuthenticationTypeType

KafkaClusterEncryptionInTransitDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import KafkaClusterEncryptionInTransitDescriptionTypeDef

def get_value() -> KafkaClusterEncryptionInTransitDescriptionTypeDef:
    return {
        "encryptionType": ...,
    }
Definition
class KafkaClusterEncryptionInTransitDescriptionTypeDef(TypedDict):
    encryptionType: NotRequired[KafkaClusterEncryptionInTransitTypeType],  # (1)
  1. See KafkaClusterEncryptionInTransitTypeType

WorkerConfigurationDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerConfigurationDescriptionTypeDef

def get_value() -> WorkerConfigurationDescriptionTypeDef:
    return {
        "revision": ...,
    }
Definition
class WorkerConfigurationDescriptionTypeDef(TypedDict):
    revision: NotRequired[int],
    workerConfigurationArn: NotRequired[str],

KafkaClusterClientAuthenticationTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import KafkaClusterClientAuthenticationTypeDef

def get_value() -> KafkaClusterClientAuthenticationTypeDef:
    return {
        "authenticationType": ...,
    }
Definition
class KafkaClusterClientAuthenticationTypeDef(TypedDict):
    authenticationType: KafkaClusterClientAuthenticationTypeType,  # (1)
  1. See KafkaClusterClientAuthenticationTypeType

KafkaClusterEncryptionInTransitTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import KafkaClusterEncryptionInTransitTypeDef

def get_value() -> KafkaClusterEncryptionInTransitTypeDef:
    return {
        "encryptionType": ...,
    }
Definition
class KafkaClusterEncryptionInTransitTypeDef(TypedDict):
    encryptionType: KafkaClusterEncryptionInTransitTypeType,  # (1)
  1. See KafkaClusterEncryptionInTransitTypeType

WorkerConfigurationTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerConfigurationTypeDef

def get_value() -> WorkerConfigurationTypeDef:
    return {
        "revision": ...,
        "workerConfigurationArn": ...,
    }
Definition
class WorkerConfigurationTypeDef(TypedDict):
    revision: int,
    workerConfigurationArn: str,

ResponseMetadataTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ResponseMetadataTypeDef

def get_value() -> ResponseMetadataTypeDef:
    return {
        "RequestId": ...,
        "HostId": ...,
        "HTTPStatusCode": ...,
        "HTTPHeaders": ...,
        "RetryAttempts": ...,
    }
Definition
class ResponseMetadataTypeDef(TypedDict):
    RequestId: str,
    HostId: str,
    HTTPStatusCode: int,
    HTTPHeaders: Dict[str, str],
    RetryAttempts: int,

CreateWorkerConfigurationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CreateWorkerConfigurationRequestRequestTypeDef

def get_value() -> CreateWorkerConfigurationRequestRequestTypeDef:
    return {
        "name": ...,
        "propertiesFileContent": ...,
    }
Definition
class CreateWorkerConfigurationRequestRequestTypeDef(TypedDict):
    name: str,
    propertiesFileContent: str,
    description: NotRequired[str],

WorkerConfigurationRevisionSummaryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerConfigurationRevisionSummaryTypeDef

def get_value() -> WorkerConfigurationRevisionSummaryTypeDef:
    return {
        "creationTime": ...,
    }
Definition
class WorkerConfigurationRevisionSummaryTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    revision: NotRequired[int],

CustomPluginDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginDescriptionTypeDef

def get_value() -> CustomPluginDescriptionTypeDef:
    return {
        "customPluginArn": ...,
    }
Definition
class CustomPluginDescriptionTypeDef(TypedDict):
    customPluginArn: NotRequired[str],
    revision: NotRequired[int],

CustomPluginFileDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginFileDescriptionTypeDef

def get_value() -> CustomPluginFileDescriptionTypeDef:
    return {
        "fileMd5": ...,
    }
Definition
class CustomPluginFileDescriptionTypeDef(TypedDict):
    fileMd5: NotRequired[str],
    fileSize: NotRequired[int],

S3LocationDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import S3LocationDescriptionTypeDef

def get_value() -> S3LocationDescriptionTypeDef:
    return {
        "bucketArn": ...,
    }
Definition
class S3LocationDescriptionTypeDef(TypedDict):
    bucketArn: NotRequired[str],
    fileKey: NotRequired[str],
    objectVersion: NotRequired[str],

S3LocationTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import S3LocationTypeDef

def get_value() -> S3LocationTypeDef:
    return {
        "bucketArn": ...,
        "fileKey": ...,
    }
Definition
class S3LocationTypeDef(TypedDict):
    bucketArn: str,
    fileKey: str,
    objectVersion: NotRequired[str],

CustomPluginTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginTypeDef

def get_value() -> CustomPluginTypeDef:
    return {
        "customPluginArn": ...,
        "revision": ...,
    }
Definition
class CustomPluginTypeDef(TypedDict):
    customPluginArn: str,
    revision: int,

DeleteConnectorRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DeleteConnectorRequestRequestTypeDef

def get_value() -> DeleteConnectorRequestRequestTypeDef:
    return {
        "connectorArn": ...,
    }
Definition
class DeleteConnectorRequestRequestTypeDef(TypedDict):
    connectorArn: str,
    currentVersion: NotRequired[str],

DeleteCustomPluginRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DeleteCustomPluginRequestRequestTypeDef

def get_value() -> DeleteCustomPluginRequestRequestTypeDef:
    return {
        "customPluginArn": ...,
    }
Definition
class DeleteCustomPluginRequestRequestTypeDef(TypedDict):
    customPluginArn: str,

DescribeConnectorRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DescribeConnectorRequestRequestTypeDef

def get_value() -> DescribeConnectorRequestRequestTypeDef:
    return {
        "connectorArn": ...,
    }
Definition
class DescribeConnectorRequestRequestTypeDef(TypedDict):
    connectorArn: str,

StateDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import StateDescriptionTypeDef

def get_value() -> StateDescriptionTypeDef:
    return {
        "code": ...,
    }
Definition
class StateDescriptionTypeDef(TypedDict):
    code: NotRequired[str],
    message: NotRequired[str],

DescribeCustomPluginRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DescribeCustomPluginRequestRequestTypeDef

def get_value() -> DescribeCustomPluginRequestRequestTypeDef:
    return {
        "customPluginArn": ...,
    }
Definition
class DescribeCustomPluginRequestRequestTypeDef(TypedDict):
    customPluginArn: str,

DescribeWorkerConfigurationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DescribeWorkerConfigurationRequestRequestTypeDef

def get_value() -> DescribeWorkerConfigurationRequestRequestTypeDef:
    return {
        "workerConfigurationArn": ...,
    }
Definition
class DescribeWorkerConfigurationRequestRequestTypeDef(TypedDict):
    workerConfigurationArn: str,

WorkerConfigurationRevisionDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerConfigurationRevisionDescriptionTypeDef

def get_value() -> WorkerConfigurationRevisionDescriptionTypeDef:
    return {
        "creationTime": ...,
    }
Definition
class WorkerConfigurationRevisionDescriptionTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    propertiesFileContent: NotRequired[str],
    revision: NotRequired[int],

FirehoseLogDeliveryDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import FirehoseLogDeliveryDescriptionTypeDef

def get_value() -> FirehoseLogDeliveryDescriptionTypeDef:
    return {
        "deliveryStream": ...,
    }
Definition
class FirehoseLogDeliveryDescriptionTypeDef(TypedDict):
    deliveryStream: NotRequired[str],
    enabled: NotRequired[bool],

FirehoseLogDeliveryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import FirehoseLogDeliveryTypeDef

def get_value() -> FirehoseLogDeliveryTypeDef:
    return {
        "enabled": ...,
    }
Definition
class FirehoseLogDeliveryTypeDef(TypedDict):
    enabled: bool,
    deliveryStream: NotRequired[str],

PaginatorConfigTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import PaginatorConfigTypeDef

def get_value() -> PaginatorConfigTypeDef:
    return {
        "MaxItems": ...,
    }
Definition
class PaginatorConfigTypeDef(TypedDict):
    MaxItems: NotRequired[int],
    PageSize: NotRequired[int],
    StartingToken: NotRequired[str],

ListConnectorsRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListConnectorsRequestRequestTypeDef

def get_value() -> ListConnectorsRequestRequestTypeDef:
    return {
        "connectorNamePrefix": ...,
    }
Definition
class ListConnectorsRequestRequestTypeDef(TypedDict):
    connectorNamePrefix: NotRequired[str],
    maxResults: NotRequired[int],
    nextToken: NotRequired[str],

ListCustomPluginsRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListCustomPluginsRequestRequestTypeDef

def get_value() -> ListCustomPluginsRequestRequestTypeDef:
    return {
        "maxResults": ...,
    }
Definition
class ListCustomPluginsRequestRequestTypeDef(TypedDict):
    maxResults: NotRequired[int],
    nextToken: NotRequired[str],

ListWorkerConfigurationsRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListWorkerConfigurationsRequestRequestTypeDef

def get_value() -> ListWorkerConfigurationsRequestRequestTypeDef:
    return {
        "maxResults": ...,
    }
Definition
class ListWorkerConfigurationsRequestRequestTypeDef(TypedDict):
    maxResults: NotRequired[int],
    nextToken: NotRequired[str],

S3LogDeliveryDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import S3LogDeliveryDescriptionTypeDef

def get_value() -> S3LogDeliveryDescriptionTypeDef:
    return {
        "bucket": ...,
    }
Definition
class S3LogDeliveryDescriptionTypeDef(TypedDict):
    bucket: NotRequired[str],
    enabled: NotRequired[bool],
    prefix: NotRequired[str],

S3LogDeliveryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import S3LogDeliveryTypeDef

def get_value() -> S3LogDeliveryTypeDef:
    return {
        "enabled": ...,
    }
Definition
class S3LogDeliveryTypeDef(TypedDict):
    enabled: bool,
    bucket: NotRequired[str],
    prefix: NotRequired[str],

ApacheKafkaClusterDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ApacheKafkaClusterDescriptionTypeDef

def get_value() -> ApacheKafkaClusterDescriptionTypeDef:
    return {
        "bootstrapServers": ...,
    }
Definition
class ApacheKafkaClusterDescriptionTypeDef(TypedDict):
    bootstrapServers: NotRequired[str],
    vpc: NotRequired[VpcDescriptionTypeDef],  # (1)
  1. See VpcDescriptionTypeDef

ApacheKafkaClusterTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ApacheKafkaClusterTypeDef

def get_value() -> ApacheKafkaClusterTypeDef:
    return {
        "bootstrapServers": ...,
        "vpc": ...,
    }
Definition
class ApacheKafkaClusterTypeDef(TypedDict):
    bootstrapServers: str,
    vpc: VpcTypeDef,  # (1)
  1. See VpcTypeDef

AutoScalingDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import AutoScalingDescriptionTypeDef

def get_value() -> AutoScalingDescriptionTypeDef:
    return {
        "maxWorkerCount": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import AutoScalingTypeDef

def get_value() -> AutoScalingTypeDef:
    return {
        "maxWorkerCount": ...,
        "mcuCount": ...,
        "minWorkerCount": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import AutoScalingUpdateTypeDef

def get_value() -> AutoScalingUpdateTypeDef:
    return {
        "maxWorkerCount": ...,
        "mcuCount": ...,
        "minWorkerCount": ...,
        "scaleInPolicy": ...,
        "scaleOutPolicy": ...,
    }
Definition
class AutoScalingUpdateTypeDef(TypedDict):
    maxWorkerCount: int,
    mcuCount: int,
    minWorkerCount: int,
    scaleInPolicy: ScaleInPolicyUpdateTypeDef,  # (1)
    scaleOutPolicy: ScaleOutPolicyUpdateTypeDef,  # (2)
  1. See ScaleInPolicyUpdateTypeDef
  2. See ScaleOutPolicyUpdateTypeDef

CreateConnectorResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CreateConnectorResponseTypeDef

def get_value() -> CreateConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
        "connectorName": ...,
        "connectorState": ...,
        "ResponseMetadata": ...,
    }
Definition
class CreateConnectorResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorName: str,
    connectorState: ConnectorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorStateType
  2. See ResponseMetadataTypeDef

CreateCustomPluginResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CreateCustomPluginResponseTypeDef

def get_value() -> CreateCustomPluginResponseTypeDef:
    return {
        "customPluginArn": ...,
        "customPluginState": ...,
        "name": ...,
        "revision": ...,
        "ResponseMetadata": ...,
    }
Definition
class CreateCustomPluginResponseTypeDef(TypedDict):
    customPluginArn: str,
    customPluginState: CustomPluginStateType,  # (1)
    name: str,
    revision: int,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CustomPluginStateType
  2. See ResponseMetadataTypeDef

DeleteConnectorResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DeleteConnectorResponseTypeDef

def get_value() -> DeleteConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
        "connectorState": ...,
        "ResponseMetadata": ...,
    }
Definition
class DeleteConnectorResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorState: ConnectorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorStateType
  2. See ResponseMetadataTypeDef

DeleteCustomPluginResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DeleteCustomPluginResponseTypeDef

def get_value() -> DeleteCustomPluginResponseTypeDef:
    return {
        "customPluginArn": ...,
        "customPluginState": ...,
        "ResponseMetadata": ...,
    }
Definition
class DeleteCustomPluginResponseTypeDef(TypedDict):
    customPluginArn: str,
    customPluginState: CustomPluginStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CustomPluginStateType
  2. See ResponseMetadataTypeDef

UpdateConnectorResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import UpdateConnectorResponseTypeDef

def get_value() -> UpdateConnectorResponseTypeDef:
    return {
        "connectorArn": ...,
        "connectorState": ...,
        "ResponseMetadata": ...,
    }
Definition
class UpdateConnectorResponseTypeDef(TypedDict):
    connectorArn: str,
    connectorState: ConnectorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorStateType
  2. See ResponseMetadataTypeDef

CreateWorkerConfigurationResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CreateWorkerConfigurationResponseTypeDef

def get_value() -> CreateWorkerConfigurationResponseTypeDef:
    return {
        "creationTime": ...,
        "latestRevision": ...,
        "name": ...,
        "workerConfigurationArn": ...,
        "ResponseMetadata": ...,
    }
Definition
class CreateWorkerConfigurationResponseTypeDef(TypedDict):
    creationTime: datetime,
    latestRevision: WorkerConfigurationRevisionSummaryTypeDef,  # (1)
    name: str,
    workerConfigurationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See WorkerConfigurationRevisionSummaryTypeDef
  2. See ResponseMetadataTypeDef

WorkerConfigurationSummaryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerConfigurationSummaryTypeDef

def get_value() -> WorkerConfigurationSummaryTypeDef:
    return {
        "creationTime": ...,
    }
Definition
class WorkerConfigurationSummaryTypeDef(TypedDict):
    creationTime: NotRequired[datetime],
    description: NotRequired[str],
    latestRevision: NotRequired[WorkerConfigurationRevisionSummaryTypeDef],  # (1)
    name: NotRequired[str],
    workerConfigurationArn: NotRequired[str],
  1. See WorkerConfigurationRevisionSummaryTypeDef

PluginDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import PluginDescriptionTypeDef

def get_value() -> PluginDescriptionTypeDef:
    return {
        "customPlugin": ...,
    }
Definition
class PluginDescriptionTypeDef(TypedDict):
    customPlugin: NotRequired[CustomPluginDescriptionTypeDef],  # (1)
  1. See CustomPluginDescriptionTypeDef

CustomPluginLocationDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginLocationDescriptionTypeDef

def get_value() -> CustomPluginLocationDescriptionTypeDef:
    return {
        "s3Location": ...,
    }
Definition
class CustomPluginLocationDescriptionTypeDef(TypedDict):
    s3Location: NotRequired[S3LocationDescriptionTypeDef],  # (1)
  1. See S3LocationDescriptionTypeDef

CustomPluginLocationTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginLocationTypeDef

def get_value() -> CustomPluginLocationTypeDef:
    return {
        "s3Location": ...,
    }
Definition
class CustomPluginLocationTypeDef(TypedDict):
    s3Location: S3LocationTypeDef,  # (1)
  1. See S3LocationTypeDef

PluginTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import PluginTypeDef

def get_value() -> PluginTypeDef:
    return {
        "customPlugin": ...,
    }
Definition
class PluginTypeDef(TypedDict):
    customPlugin: CustomPluginTypeDef,  # (1)
  1. See CustomPluginTypeDef

DescribeWorkerConfigurationResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DescribeWorkerConfigurationResponseTypeDef

def get_value() -> DescribeWorkerConfigurationResponseTypeDef:
    return {
        "creationTime": ...,
        "description": ...,
        "latestRevision": ...,
        "name": ...,
        "workerConfigurationArn": ...,
        "ResponseMetadata": ...,
    }
Definition
class DescribeWorkerConfigurationResponseTypeDef(TypedDict):
    creationTime: datetime,
    description: str,
    latestRevision: WorkerConfigurationRevisionDescriptionTypeDef,  # (1)
    name: str,
    workerConfigurationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See WorkerConfigurationRevisionDescriptionTypeDef
  2. See ResponseMetadataTypeDef

ListConnectorsRequestListConnectorsPaginateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListConnectorsRequestListConnectorsPaginateTypeDef

def get_value() -> ListConnectorsRequestListConnectorsPaginateTypeDef:
    return {
        "connectorNamePrefix": ...,
    }
Definition
class ListConnectorsRequestListConnectorsPaginateTypeDef(TypedDict):
    connectorNamePrefix: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListCustomPluginsRequestListCustomPluginsPaginateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListCustomPluginsRequestListCustomPluginsPaginateTypeDef

def get_value() -> ListCustomPluginsRequestListCustomPluginsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
Definition
class ListCustomPluginsRequestListCustomPluginsPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef

def get_value() -> ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
Definition
class ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

WorkerLogDeliveryDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerLogDeliveryDescriptionTypeDef

def get_value() -> WorkerLogDeliveryDescriptionTypeDef:
    return {
        "cloudWatchLogs": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import WorkerLogDeliveryTypeDef

def get_value() -> WorkerLogDeliveryTypeDef:
    return {
        "cloudWatchLogs": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import KafkaClusterDescriptionTypeDef

def get_value() -> KafkaClusterDescriptionTypeDef:
    return {
        "apacheKafkaCluster": ...,
    }
Definition
class KafkaClusterDescriptionTypeDef(TypedDict):
    apacheKafkaCluster: NotRequired[ApacheKafkaClusterDescriptionTypeDef],  # (1)
  1. See ApacheKafkaClusterDescriptionTypeDef

KafkaClusterTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import KafkaClusterTypeDef

def get_value() -> KafkaClusterTypeDef:
    return {
        "apacheKafkaCluster": ...,
    }
Definition
class KafkaClusterTypeDef(TypedDict):
    apacheKafkaCluster: ApacheKafkaClusterTypeDef,  # (1)
  1. See ApacheKafkaClusterTypeDef

CapacityDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CapacityDescriptionTypeDef

def get_value() -> CapacityDescriptionTypeDef:
    return {
        "autoScaling": ...,
    }
Definition
class CapacityDescriptionTypeDef(TypedDict):
    autoScaling: NotRequired[AutoScalingDescriptionTypeDef],  # (1)
    provisionedCapacity: NotRequired[ProvisionedCapacityDescriptionTypeDef],  # (2)
  1. See AutoScalingDescriptionTypeDef
  2. See ProvisionedCapacityDescriptionTypeDef

CapacityTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CapacityTypeDef

def get_value() -> CapacityTypeDef:
    return {
        "autoScaling": ...,
    }
Definition
class CapacityTypeDef(TypedDict):
    autoScaling: NotRequired[AutoScalingTypeDef],  # (1)
    provisionedCapacity: NotRequired[ProvisionedCapacityTypeDef],  # (2)
  1. See AutoScalingTypeDef
  2. See ProvisionedCapacityTypeDef

CapacityUpdateTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CapacityUpdateTypeDef

def get_value() -> CapacityUpdateTypeDef:
    return {
        "autoScaling": ...,
    }
Definition
class CapacityUpdateTypeDef(TypedDict):
    autoScaling: NotRequired[AutoScalingUpdateTypeDef],  # (1)
    provisionedCapacity: NotRequired[ProvisionedCapacityUpdateTypeDef],  # (2)
  1. See AutoScalingUpdateTypeDef
  2. See ProvisionedCapacityUpdateTypeDef

ListWorkerConfigurationsResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListWorkerConfigurationsResponseTypeDef

def get_value() -> ListWorkerConfigurationsResponseTypeDef:
    return {
        "nextToken": ...,
        "workerConfigurations": ...,
        "ResponseMetadata": ...,
    }
Definition
class ListWorkerConfigurationsResponseTypeDef(TypedDict):
    nextToken: str,
    workerConfigurations: List[WorkerConfigurationSummaryTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See WorkerConfigurationSummaryTypeDef
  2. See ResponseMetadataTypeDef

CustomPluginRevisionSummaryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginRevisionSummaryTypeDef

def get_value() -> CustomPluginRevisionSummaryTypeDef:
    return {
        "contentType": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CreateCustomPluginRequestRequestTypeDef

def get_value() -> CreateCustomPluginRequestRequestTypeDef:
    return {
        "contentType": ...,
        "location": ...,
        "name": ...,
    }
Definition
class CreateCustomPluginRequestRequestTypeDef(TypedDict):
    contentType: CustomPluginContentTypeType,  # (1)
    location: CustomPluginLocationTypeDef,  # (2)
    name: str,
    description: NotRequired[str],
  1. See CustomPluginContentTypeType
  2. See CustomPluginLocationTypeDef

LogDeliveryDescriptionTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import LogDeliveryDescriptionTypeDef

def get_value() -> LogDeliveryDescriptionTypeDef:
    return {
        "workerLogDelivery": ...,
    }
Definition
class LogDeliveryDescriptionTypeDef(TypedDict):
    workerLogDelivery: NotRequired[WorkerLogDeliveryDescriptionTypeDef],  # (1)
  1. See WorkerLogDeliveryDescriptionTypeDef

LogDeliveryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import LogDeliveryTypeDef

def get_value() -> LogDeliveryTypeDef:
    return {
        "workerLogDelivery": ...,
    }
Definition
class LogDeliveryTypeDef(TypedDict):
    workerLogDelivery: WorkerLogDeliveryTypeDef,  # (1)
  1. See WorkerLogDeliveryTypeDef

UpdateConnectorRequestRequestTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import UpdateConnectorRequestRequestTypeDef

def get_value() -> UpdateConnectorRequestRequestTypeDef:
    return {
        "capacity": ...,
        "connectorArn": ...,
        "currentVersion": ...,
    }
Definition
class UpdateConnectorRequestRequestTypeDef(TypedDict):
    capacity: CapacityUpdateTypeDef,  # (1)
    connectorArn: str,
    currentVersion: str,
  1. See CapacityUpdateTypeDef

CustomPluginSummaryTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CustomPluginSummaryTypeDef

def get_value() -> CustomPluginSummaryTypeDef:
    return {
        "creationTime": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import DescribeCustomPluginResponseTypeDef

def get_value() -> DescribeCustomPluginResponseTypeDef:
    return {
        "creationTime": ...,
        "customPluginArn": ...,
        "customPluginState": ...,
        "description": ...,
        "latestRevision": ...,
        "name": ...,
        "stateDescription": ...,
        "ResponseMetadata": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ConnectorSummaryTypeDef

def get_value() -> ConnectorSummaryTypeDef:
    return {
        "capacity": ...,
    }
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

Usage Example
from types_aiobotocore_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": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import CreateConnectorRequestRequestTypeDef

def get_value() -> CreateConnectorRequestRequestTypeDef:
    return {
        "capacity": ...,
        "connectorConfiguration": ...,
        "connectorName": ...,
        "kafkaCluster": ...,
        "kafkaClusterClientAuthentication": ...,
        "kafkaClusterEncryptionInTransit": ...,
        "kafkaConnectVersion": ...,
        "plugins": ...,
        "serviceExecutionRoleArn": ...,
    }
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

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListCustomPluginsResponseTypeDef

def get_value() -> ListCustomPluginsResponseTypeDef:
    return {
        "customPlugins": ...,
        "nextToken": ...,
        "ResponseMetadata": ...,
    }
Definition
class ListCustomPluginsResponseTypeDef(TypedDict):
    customPlugins: List[CustomPluginSummaryTypeDef],  # (1)
    nextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CustomPluginSummaryTypeDef
  2. See ResponseMetadataTypeDef

ListConnectorsResponseTypeDef

Usage Example
from types_aiobotocore_kafkaconnect.type_defs import ListConnectorsResponseTypeDef

def get_value() -> ListConnectorsResponseTypeDef:
    return {
        "connectors": ...,
        "nextToken": ...,
        "ResponseMetadata": ...,
    }
Definition
class ListConnectorsResponseTypeDef(TypedDict):
    connectors: List[ConnectorSummaryTypeDef],  # (1)
    nextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConnectorSummaryTypeDef
  2. See ResponseMetadataTypeDef