Typed dictionaries#
Index > KafkaConnect > Typed dictionaries
Auto-generated documentation for KafkaConnect type annotations stubs module mypy-boto3-kafkaconnect.
VpcDescriptionTypeDef#
# VpcDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import VpcDescriptionTypeDef
def get_value() -> VpcDescriptionTypeDef:
return {
"securityGroups": ...,
}
# VpcDescriptionTypeDef definition
class VpcDescriptionTypeDef(TypedDict):
securityGroups: NotRequired[List[str]],
subnets: NotRequired[List[str]],
VpcTypeDef#
# VpcTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import VpcTypeDef
def get_value() -> VpcTypeDef:
return {
"subnets": ...,
}
# VpcTypeDef definition
class VpcTypeDef(TypedDict):
subnets: Sequence[str],
securityGroups: NotRequired[Sequence[str]],
ScaleInPolicyDescriptionTypeDef#
# ScaleInPolicyDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ScaleInPolicyDescriptionTypeDef
def get_value() -> ScaleInPolicyDescriptionTypeDef:
return {
"cpuUtilizationPercentage": ...,
}
# ScaleInPolicyDescriptionTypeDef definition
class ScaleInPolicyDescriptionTypeDef(TypedDict):
cpuUtilizationPercentage: NotRequired[int],
ScaleOutPolicyDescriptionTypeDef#
# ScaleOutPolicyDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ScaleOutPolicyDescriptionTypeDef
def get_value() -> ScaleOutPolicyDescriptionTypeDef:
return {
"cpuUtilizationPercentage": ...,
}
# ScaleOutPolicyDescriptionTypeDef definition
class ScaleOutPolicyDescriptionTypeDef(TypedDict):
cpuUtilizationPercentage: NotRequired[int],
ScaleInPolicyTypeDef#
# ScaleInPolicyTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ScaleInPolicyTypeDef
def get_value() -> ScaleInPolicyTypeDef:
return {
"cpuUtilizationPercentage": ...,
}
# ScaleInPolicyTypeDef definition
class ScaleInPolicyTypeDef(TypedDict):
cpuUtilizationPercentage: int,
ScaleOutPolicyTypeDef#
# ScaleOutPolicyTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ScaleOutPolicyTypeDef
def get_value() -> ScaleOutPolicyTypeDef:
return {
"cpuUtilizationPercentage": ...,
}
# ScaleOutPolicyTypeDef definition
class ScaleOutPolicyTypeDef(TypedDict):
cpuUtilizationPercentage: int,
ScaleInPolicyUpdateTypeDef#
# ScaleInPolicyUpdateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ScaleInPolicyUpdateTypeDef
def get_value() -> ScaleInPolicyUpdateTypeDef:
return {
"cpuUtilizationPercentage": ...,
}
# ScaleInPolicyUpdateTypeDef definition
class ScaleInPolicyUpdateTypeDef(TypedDict):
cpuUtilizationPercentage: int,
ScaleOutPolicyUpdateTypeDef#
# ScaleOutPolicyUpdateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ScaleOutPolicyUpdateTypeDef
def get_value() -> ScaleOutPolicyUpdateTypeDef:
return {
"cpuUtilizationPercentage": ...,
}
# ScaleOutPolicyUpdateTypeDef definition
class ScaleOutPolicyUpdateTypeDef(TypedDict):
cpuUtilizationPercentage: int,
ProvisionedCapacityDescriptionTypeDef#
# ProvisionedCapacityDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ProvisionedCapacityDescriptionTypeDef
def get_value() -> ProvisionedCapacityDescriptionTypeDef:
return {
"mcuCount": ...,
}
# ProvisionedCapacityDescriptionTypeDef definition
class ProvisionedCapacityDescriptionTypeDef(TypedDict):
mcuCount: NotRequired[int],
workerCount: NotRequired[int],
ProvisionedCapacityTypeDef#
# ProvisionedCapacityTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ProvisionedCapacityTypeDef
def get_value() -> ProvisionedCapacityTypeDef:
return {
"mcuCount": ...,
"workerCount": ...,
}
# ProvisionedCapacityTypeDef definition
class ProvisionedCapacityTypeDef(TypedDict):
mcuCount: int,
workerCount: int,
ProvisionedCapacityUpdateTypeDef#
# ProvisionedCapacityUpdateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ProvisionedCapacityUpdateTypeDef
def get_value() -> ProvisionedCapacityUpdateTypeDef:
return {
"mcuCount": ...,
"workerCount": ...,
}
# ProvisionedCapacityUpdateTypeDef definition
class ProvisionedCapacityUpdateTypeDef(TypedDict):
mcuCount: int,
workerCount: int,
CloudWatchLogsLogDeliveryDescriptionTypeDef#
# CloudWatchLogsLogDeliveryDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryDescriptionTypeDef
def get_value() -> CloudWatchLogsLogDeliveryDescriptionTypeDef:
return {
"enabled": ...,
}
# CloudWatchLogsLogDeliveryDescriptionTypeDef definition
class CloudWatchLogsLogDeliveryDescriptionTypeDef(TypedDict):
enabled: NotRequired[bool],
logGroup: NotRequired[str],
CloudWatchLogsLogDeliveryTypeDef#
# CloudWatchLogsLogDeliveryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CloudWatchLogsLogDeliveryTypeDef
def get_value() -> CloudWatchLogsLogDeliveryTypeDef:
return {
"enabled": ...,
}
# CloudWatchLogsLogDeliveryTypeDef definition
class CloudWatchLogsLogDeliveryTypeDef(TypedDict):
enabled: bool,
logGroup: NotRequired[str],
KafkaClusterClientAuthenticationDescriptionTypeDef#
# KafkaClusterClientAuthenticationDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import KafkaClusterClientAuthenticationDescriptionTypeDef
def get_value() -> KafkaClusterClientAuthenticationDescriptionTypeDef:
return {
"authenticationType": ...,
}
# KafkaClusterClientAuthenticationDescriptionTypeDef definition
class KafkaClusterClientAuthenticationDescriptionTypeDef(TypedDict):
authenticationType: NotRequired[KafkaClusterClientAuthenticationTypeType], # (1)
KafkaClusterEncryptionInTransitDescriptionTypeDef#
# KafkaClusterEncryptionInTransitDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import KafkaClusterEncryptionInTransitDescriptionTypeDef
def get_value() -> KafkaClusterEncryptionInTransitDescriptionTypeDef:
return {
"encryptionType": ...,
}
# KafkaClusterEncryptionInTransitDescriptionTypeDef definition
class KafkaClusterEncryptionInTransitDescriptionTypeDef(TypedDict):
encryptionType: NotRequired[KafkaClusterEncryptionInTransitTypeType], # (1)
WorkerConfigurationDescriptionTypeDef#
# WorkerConfigurationDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationDescriptionTypeDef
def get_value() -> WorkerConfigurationDescriptionTypeDef:
return {
"revision": ...,
}
# WorkerConfigurationDescriptionTypeDef definition
class WorkerConfigurationDescriptionTypeDef(TypedDict):
revision: NotRequired[int],
workerConfigurationArn: NotRequired[str],
KafkaClusterClientAuthenticationTypeDef#
# KafkaClusterClientAuthenticationTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import KafkaClusterClientAuthenticationTypeDef
def get_value() -> KafkaClusterClientAuthenticationTypeDef:
return {
"authenticationType": ...,
}
# KafkaClusterClientAuthenticationTypeDef definition
class KafkaClusterClientAuthenticationTypeDef(TypedDict):
authenticationType: KafkaClusterClientAuthenticationTypeType, # (1)
KafkaClusterEncryptionInTransitTypeDef#
# KafkaClusterEncryptionInTransitTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import KafkaClusterEncryptionInTransitTypeDef
def get_value() -> KafkaClusterEncryptionInTransitTypeDef:
return {
"encryptionType": ...,
}
# KafkaClusterEncryptionInTransitTypeDef definition
class KafkaClusterEncryptionInTransitTypeDef(TypedDict):
encryptionType: KafkaClusterEncryptionInTransitTypeType, # (1)
WorkerConfigurationTypeDef#
# WorkerConfigurationTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationTypeDef
def get_value() -> WorkerConfigurationTypeDef:
return {
"revision": ...,
"workerConfigurationArn": ...,
}
# WorkerConfigurationTypeDef definition
class WorkerConfigurationTypeDef(TypedDict):
revision: int,
workerConfigurationArn: str,
CreateConnectorResponseTypeDef#
# CreateConnectorResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CreateConnectorResponseTypeDef
def get_value() -> CreateConnectorResponseTypeDef:
return {
"connectorArn": ...,
"connectorName": ...,
"connectorState": ...,
"ResponseMetadata": ...,
}
# CreateConnectorResponseTypeDef definition
class CreateConnectorResponseTypeDef(TypedDict):
connectorArn: str,
connectorName: str,
connectorState: ConnectorStateType, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
CreateCustomPluginResponseTypeDef#
# CreateCustomPluginResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CreateCustomPluginResponseTypeDef
def get_value() -> CreateCustomPluginResponseTypeDef:
return {
"customPluginArn": ...,
"customPluginState": ...,
"name": ...,
"revision": ...,
"ResponseMetadata": ...,
}
# CreateCustomPluginResponseTypeDef definition
class CreateCustomPluginResponseTypeDef(TypedDict):
customPluginArn: str,
customPluginState: CustomPluginStateType, # (1)
name: str,
revision: int,
ResponseMetadata: ResponseMetadataTypeDef, # (2)
CreateWorkerConfigurationRequestRequestTypeDef#
# CreateWorkerConfigurationRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CreateWorkerConfigurationRequestRequestTypeDef
def get_value() -> CreateWorkerConfigurationRequestRequestTypeDef:
return {
"name": ...,
"propertiesFileContent": ...,
}
# CreateWorkerConfigurationRequestRequestTypeDef definition
class CreateWorkerConfigurationRequestRequestTypeDef(TypedDict):
name: str,
propertiesFileContent: str,
description: NotRequired[str],
WorkerConfigurationRevisionSummaryTypeDef#
# WorkerConfigurationRevisionSummaryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationRevisionSummaryTypeDef
def get_value() -> WorkerConfigurationRevisionSummaryTypeDef:
return {
"creationTime": ...,
}
# WorkerConfigurationRevisionSummaryTypeDef definition
class WorkerConfigurationRevisionSummaryTypeDef(TypedDict):
creationTime: NotRequired[datetime],
description: NotRequired[str],
revision: NotRequired[int],
CustomPluginDescriptionTypeDef#
# CustomPluginDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginDescriptionTypeDef
def get_value() -> CustomPluginDescriptionTypeDef:
return {
"customPluginArn": ...,
}
# CustomPluginDescriptionTypeDef definition
class CustomPluginDescriptionTypeDef(TypedDict):
customPluginArn: NotRequired[str],
revision: NotRequired[int],
CustomPluginFileDescriptionTypeDef#
# CustomPluginFileDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginFileDescriptionTypeDef
def get_value() -> CustomPluginFileDescriptionTypeDef:
return {
"fileMd5": ...,
}
# CustomPluginFileDescriptionTypeDef definition
class CustomPluginFileDescriptionTypeDef(TypedDict):
fileMd5: NotRequired[str],
fileSize: NotRequired[int],
S3LocationDescriptionTypeDef#
# S3LocationDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import S3LocationDescriptionTypeDef
def get_value() -> S3LocationDescriptionTypeDef:
return {
"bucketArn": ...,
}
# S3LocationDescriptionTypeDef definition
class S3LocationDescriptionTypeDef(TypedDict):
bucketArn: NotRequired[str],
fileKey: NotRequired[str],
objectVersion: NotRequired[str],
S3LocationTypeDef#
# S3LocationTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import S3LocationTypeDef
def get_value() -> S3LocationTypeDef:
return {
"bucketArn": ...,
"fileKey": ...,
}
# S3LocationTypeDef definition
class S3LocationTypeDef(TypedDict):
bucketArn: str,
fileKey: str,
objectVersion: NotRequired[str],
CustomPluginTypeDef#
# CustomPluginTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginTypeDef
def get_value() -> CustomPluginTypeDef:
return {
"customPluginArn": ...,
"revision": ...,
}
# CustomPluginTypeDef definition
class CustomPluginTypeDef(TypedDict):
customPluginArn: str,
revision: int,
DeleteConnectorRequestRequestTypeDef#
# DeleteConnectorRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DeleteConnectorRequestRequestTypeDef
def get_value() -> DeleteConnectorRequestRequestTypeDef:
return {
"connectorArn": ...,
}
# DeleteConnectorRequestRequestTypeDef definition
class DeleteConnectorRequestRequestTypeDef(TypedDict):
connectorArn: str,
currentVersion: NotRequired[str],
DeleteConnectorResponseTypeDef#
# DeleteConnectorResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DeleteConnectorResponseTypeDef
def get_value() -> DeleteConnectorResponseTypeDef:
return {
"connectorArn": ...,
"connectorState": ...,
"ResponseMetadata": ...,
}
# DeleteConnectorResponseTypeDef definition
class DeleteConnectorResponseTypeDef(TypedDict):
connectorArn: str,
connectorState: ConnectorStateType, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
DeleteCustomPluginRequestRequestTypeDef#
# DeleteCustomPluginRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DeleteCustomPluginRequestRequestTypeDef
def get_value() -> DeleteCustomPluginRequestRequestTypeDef:
return {
"customPluginArn": ...,
}
# DeleteCustomPluginRequestRequestTypeDef definition
class DeleteCustomPluginRequestRequestTypeDef(TypedDict):
customPluginArn: str,
DeleteCustomPluginResponseTypeDef#
# DeleteCustomPluginResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DeleteCustomPluginResponseTypeDef
def get_value() -> DeleteCustomPluginResponseTypeDef:
return {
"customPluginArn": ...,
"customPluginState": ...,
"ResponseMetadata": ...,
}
# DeleteCustomPluginResponseTypeDef definition
class DeleteCustomPluginResponseTypeDef(TypedDict):
customPluginArn: str,
customPluginState: CustomPluginStateType, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
DescribeConnectorRequestRequestTypeDef#
# DescribeConnectorRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DescribeConnectorRequestRequestTypeDef
def get_value() -> DescribeConnectorRequestRequestTypeDef:
return {
"connectorArn": ...,
}
# DescribeConnectorRequestRequestTypeDef definition
class DescribeConnectorRequestRequestTypeDef(TypedDict):
connectorArn: str,
StateDescriptionTypeDef#
# StateDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import StateDescriptionTypeDef
def get_value() -> StateDescriptionTypeDef:
return {
"code": ...,
}
# StateDescriptionTypeDef definition
class StateDescriptionTypeDef(TypedDict):
code: NotRequired[str],
message: NotRequired[str],
DescribeCustomPluginRequestRequestTypeDef#
# DescribeCustomPluginRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DescribeCustomPluginRequestRequestTypeDef
def get_value() -> DescribeCustomPluginRequestRequestTypeDef:
return {
"customPluginArn": ...,
}
# DescribeCustomPluginRequestRequestTypeDef definition
class DescribeCustomPluginRequestRequestTypeDef(TypedDict):
customPluginArn: str,
DescribeWorkerConfigurationRequestRequestTypeDef#
# DescribeWorkerConfigurationRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DescribeWorkerConfigurationRequestRequestTypeDef
def get_value() -> DescribeWorkerConfigurationRequestRequestTypeDef:
return {
"workerConfigurationArn": ...,
}
# DescribeWorkerConfigurationRequestRequestTypeDef definition
class DescribeWorkerConfigurationRequestRequestTypeDef(TypedDict):
workerConfigurationArn: str,
WorkerConfigurationRevisionDescriptionTypeDef#
# WorkerConfigurationRevisionDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationRevisionDescriptionTypeDef
def get_value() -> WorkerConfigurationRevisionDescriptionTypeDef:
return {
"creationTime": ...,
}
# WorkerConfigurationRevisionDescriptionTypeDef definition
class WorkerConfigurationRevisionDescriptionTypeDef(TypedDict):
creationTime: NotRequired[datetime],
description: NotRequired[str],
propertiesFileContent: NotRequired[str],
revision: NotRequired[int],
FirehoseLogDeliveryDescriptionTypeDef#
# FirehoseLogDeliveryDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import FirehoseLogDeliveryDescriptionTypeDef
def get_value() -> FirehoseLogDeliveryDescriptionTypeDef:
return {
"deliveryStream": ...,
}
# FirehoseLogDeliveryDescriptionTypeDef definition
class FirehoseLogDeliveryDescriptionTypeDef(TypedDict):
deliveryStream: NotRequired[str],
enabled: NotRequired[bool],
FirehoseLogDeliveryTypeDef#
# FirehoseLogDeliveryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import FirehoseLogDeliveryTypeDef
def get_value() -> FirehoseLogDeliveryTypeDef:
return {
"enabled": ...,
}
# FirehoseLogDeliveryTypeDef definition
class FirehoseLogDeliveryTypeDef(TypedDict):
enabled: bool,
deliveryStream: NotRequired[str],
ListConnectorsRequestListConnectorsPaginateTypeDef#
# ListConnectorsRequestListConnectorsPaginateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListConnectorsRequestListConnectorsPaginateTypeDef
def get_value() -> ListConnectorsRequestListConnectorsPaginateTypeDef:
return {
"connectorNamePrefix": ...,
}
# ListConnectorsRequestListConnectorsPaginateTypeDef definition
class ListConnectorsRequestListConnectorsPaginateTypeDef(TypedDict):
connectorNamePrefix: NotRequired[str],
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListConnectorsRequestRequestTypeDef#
# ListConnectorsRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListConnectorsRequestRequestTypeDef
def get_value() -> ListConnectorsRequestRequestTypeDef:
return {
"connectorNamePrefix": ...,
}
# ListConnectorsRequestRequestTypeDef definition
class ListConnectorsRequestRequestTypeDef(TypedDict):
connectorNamePrefix: NotRequired[str],
maxResults: NotRequired[int],
nextToken: NotRequired[str],
ListCustomPluginsRequestListCustomPluginsPaginateTypeDef#
# ListCustomPluginsRequestListCustomPluginsPaginateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListCustomPluginsRequestListCustomPluginsPaginateTypeDef
def get_value() -> ListCustomPluginsRequestListCustomPluginsPaginateTypeDef:
return {
"PaginationConfig": ...,
}
# ListCustomPluginsRequestListCustomPluginsPaginateTypeDef definition
class ListCustomPluginsRequestListCustomPluginsPaginateTypeDef(TypedDict):
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListCustomPluginsRequestRequestTypeDef#
# ListCustomPluginsRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListCustomPluginsRequestRequestTypeDef
def get_value() -> ListCustomPluginsRequestRequestTypeDef:
return {
"maxResults": ...,
}
# ListCustomPluginsRequestRequestTypeDef definition
class ListCustomPluginsRequestRequestTypeDef(TypedDict):
maxResults: NotRequired[int],
nextToken: NotRequired[str],
ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef#
# ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef
def get_value() -> ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef:
return {
"PaginationConfig": ...,
}
# ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef definition
class ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef(TypedDict):
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListWorkerConfigurationsRequestRequestTypeDef#
# ListWorkerConfigurationsRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsRequestRequestTypeDef
def get_value() -> ListWorkerConfigurationsRequestRequestTypeDef:
return {
"maxResults": ...,
}
# ListWorkerConfigurationsRequestRequestTypeDef definition
class ListWorkerConfigurationsRequestRequestTypeDef(TypedDict):
maxResults: NotRequired[int],
nextToken: NotRequired[str],
PaginatorConfigTypeDef#
# PaginatorConfigTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import PaginatorConfigTypeDef
def get_value() -> PaginatorConfigTypeDef:
return {
"MaxItems": ...,
}
# PaginatorConfigTypeDef definition
class PaginatorConfigTypeDef(TypedDict):
MaxItems: NotRequired[int],
PageSize: NotRequired[int],
StartingToken: NotRequired[str],
ResponseMetadataTypeDef#
# ResponseMetadataTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ResponseMetadataTypeDef
def get_value() -> ResponseMetadataTypeDef:
return {
"RequestId": ...,
"HostId": ...,
"HTTPStatusCode": ...,
"HTTPHeaders": ...,
"RetryAttempts": ...,
}
# ResponseMetadataTypeDef definition
class ResponseMetadataTypeDef(TypedDict):
RequestId: str,
HostId: str,
HTTPStatusCode: int,
HTTPHeaders: Dict[str, str],
RetryAttempts: int,
S3LogDeliveryDescriptionTypeDef#
# S3LogDeliveryDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import S3LogDeliveryDescriptionTypeDef
def get_value() -> S3LogDeliveryDescriptionTypeDef:
return {
"bucket": ...,
}
# S3LogDeliveryDescriptionTypeDef definition
class S3LogDeliveryDescriptionTypeDef(TypedDict):
bucket: NotRequired[str],
enabled: NotRequired[bool],
prefix: NotRequired[str],
S3LogDeliveryTypeDef#
# S3LogDeliveryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import S3LogDeliveryTypeDef
def get_value() -> S3LogDeliveryTypeDef:
return {
"enabled": ...,
}
# S3LogDeliveryTypeDef definition
class S3LogDeliveryTypeDef(TypedDict):
enabled: bool,
bucket: NotRequired[str],
prefix: NotRequired[str],
UpdateConnectorResponseTypeDef#
# UpdateConnectorResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import UpdateConnectorResponseTypeDef
def get_value() -> UpdateConnectorResponseTypeDef:
return {
"connectorArn": ...,
"connectorState": ...,
"ResponseMetadata": ...,
}
# UpdateConnectorResponseTypeDef definition
class UpdateConnectorResponseTypeDef(TypedDict):
connectorArn: str,
connectorState: ConnectorStateType, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
ApacheKafkaClusterDescriptionTypeDef#
# ApacheKafkaClusterDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ApacheKafkaClusterDescriptionTypeDef
def get_value() -> ApacheKafkaClusterDescriptionTypeDef:
return {
"bootstrapServers": ...,
}
# ApacheKafkaClusterDescriptionTypeDef definition
class ApacheKafkaClusterDescriptionTypeDef(TypedDict):
bootstrapServers: NotRequired[str],
vpc: NotRequired[VpcDescriptionTypeDef], # (1)
ApacheKafkaClusterTypeDef#
# ApacheKafkaClusterTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ApacheKafkaClusterTypeDef
def get_value() -> ApacheKafkaClusterTypeDef:
return {
"bootstrapServers": ...,
"vpc": ...,
}
# ApacheKafkaClusterTypeDef definition
class ApacheKafkaClusterTypeDef(TypedDict):
bootstrapServers: str,
vpc: VpcTypeDef, # (1)
- See VpcTypeDef
AutoScalingDescriptionTypeDef#
# AutoScalingDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import AutoScalingDescriptionTypeDef
def get_value() -> AutoScalingDescriptionTypeDef:
return {
"maxWorkerCount": ...,
}
# AutoScalingDescriptionTypeDef definition
class AutoScalingDescriptionTypeDef(TypedDict):
maxWorkerCount: NotRequired[int],
mcuCount: NotRequired[int],
minWorkerCount: NotRequired[int],
scaleInPolicy: NotRequired[ScaleInPolicyDescriptionTypeDef], # (1)
scaleOutPolicy: NotRequired[ScaleOutPolicyDescriptionTypeDef], # (2)
AutoScalingTypeDef#
# AutoScalingTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import AutoScalingTypeDef
def get_value() -> AutoScalingTypeDef:
return {
"maxWorkerCount": ...,
"mcuCount": ...,
"minWorkerCount": ...,
}
# AutoScalingTypeDef definition
class AutoScalingTypeDef(TypedDict):
maxWorkerCount: int,
mcuCount: int,
minWorkerCount: int,
scaleInPolicy: NotRequired[ScaleInPolicyTypeDef], # (1)
scaleOutPolicy: NotRequired[ScaleOutPolicyTypeDef], # (2)
AutoScalingUpdateTypeDef#
# AutoScalingUpdateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import AutoScalingUpdateTypeDef
def get_value() -> AutoScalingUpdateTypeDef:
return {
"maxWorkerCount": ...,
"mcuCount": ...,
"minWorkerCount": ...,
"scaleInPolicy": ...,
"scaleOutPolicy": ...,
}
# AutoScalingUpdateTypeDef definition
class AutoScalingUpdateTypeDef(TypedDict):
maxWorkerCount: int,
mcuCount: int,
minWorkerCount: int,
scaleInPolicy: ScaleInPolicyUpdateTypeDef, # (1)
scaleOutPolicy: ScaleOutPolicyUpdateTypeDef, # (2)
CreateWorkerConfigurationResponseTypeDef#
# CreateWorkerConfigurationResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CreateWorkerConfigurationResponseTypeDef
def get_value() -> CreateWorkerConfigurationResponseTypeDef:
return {
"creationTime": ...,
"latestRevision": ...,
"name": ...,
"workerConfigurationArn": ...,
"ResponseMetadata": ...,
}
# CreateWorkerConfigurationResponseTypeDef definition
class CreateWorkerConfigurationResponseTypeDef(TypedDict):
creationTime: datetime,
latestRevision: WorkerConfigurationRevisionSummaryTypeDef, # (1)
name: str,
workerConfigurationArn: str,
ResponseMetadata: ResponseMetadataTypeDef, # (2)
WorkerConfigurationSummaryTypeDef#
# WorkerConfigurationSummaryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerConfigurationSummaryTypeDef
def get_value() -> WorkerConfigurationSummaryTypeDef:
return {
"creationTime": ...,
}
# WorkerConfigurationSummaryTypeDef definition
class WorkerConfigurationSummaryTypeDef(TypedDict):
creationTime: NotRequired[datetime],
description: NotRequired[str],
latestRevision: NotRequired[WorkerConfigurationRevisionSummaryTypeDef], # (1)
name: NotRequired[str],
workerConfigurationArn: NotRequired[str],
PluginDescriptionTypeDef#
# PluginDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import PluginDescriptionTypeDef
def get_value() -> PluginDescriptionTypeDef:
return {
"customPlugin": ...,
}
# PluginDescriptionTypeDef definition
class PluginDescriptionTypeDef(TypedDict):
customPlugin: NotRequired[CustomPluginDescriptionTypeDef], # (1)
CustomPluginLocationDescriptionTypeDef#
# CustomPluginLocationDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginLocationDescriptionTypeDef
def get_value() -> CustomPluginLocationDescriptionTypeDef:
return {
"s3Location": ...,
}
# CustomPluginLocationDescriptionTypeDef definition
class CustomPluginLocationDescriptionTypeDef(TypedDict):
s3Location: NotRequired[S3LocationDescriptionTypeDef], # (1)
CustomPluginLocationTypeDef#
# CustomPluginLocationTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginLocationTypeDef
def get_value() -> CustomPluginLocationTypeDef:
return {
"s3Location": ...,
}
# CustomPluginLocationTypeDef definition
class CustomPluginLocationTypeDef(TypedDict):
s3Location: S3LocationTypeDef, # (1)
PluginTypeDef#
# PluginTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import PluginTypeDef
def get_value() -> PluginTypeDef:
return {
"customPlugin": ...,
}
# PluginTypeDef definition
class PluginTypeDef(TypedDict):
customPlugin: CustomPluginTypeDef, # (1)
DescribeWorkerConfigurationResponseTypeDef#
# DescribeWorkerConfigurationResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DescribeWorkerConfigurationResponseTypeDef
def get_value() -> DescribeWorkerConfigurationResponseTypeDef:
return {
"creationTime": ...,
"description": ...,
"latestRevision": ...,
"name": ...,
"workerConfigurationArn": ...,
"ResponseMetadata": ...,
}
# DescribeWorkerConfigurationResponseTypeDef definition
class DescribeWorkerConfigurationResponseTypeDef(TypedDict):
creationTime: datetime,
description: str,
latestRevision: WorkerConfigurationRevisionDescriptionTypeDef, # (1)
name: str,
workerConfigurationArn: str,
ResponseMetadata: ResponseMetadataTypeDef, # (2)
WorkerLogDeliveryDescriptionTypeDef#
# WorkerLogDeliveryDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerLogDeliveryDescriptionTypeDef
def get_value() -> WorkerLogDeliveryDescriptionTypeDef:
return {
"cloudWatchLogs": ...,
}
# WorkerLogDeliveryDescriptionTypeDef definition
class WorkerLogDeliveryDescriptionTypeDef(TypedDict):
cloudWatchLogs: NotRequired[CloudWatchLogsLogDeliveryDescriptionTypeDef], # (1)
firehose: NotRequired[FirehoseLogDeliveryDescriptionTypeDef], # (2)
s3: NotRequired[S3LogDeliveryDescriptionTypeDef], # (3)
- See CloudWatchLogsLogDeliveryDescriptionTypeDef
- See FirehoseLogDeliveryDescriptionTypeDef
- See S3LogDeliveryDescriptionTypeDef
WorkerLogDeliveryTypeDef#
# WorkerLogDeliveryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import WorkerLogDeliveryTypeDef
def get_value() -> WorkerLogDeliveryTypeDef:
return {
"cloudWatchLogs": ...,
}
# WorkerLogDeliveryTypeDef definition
class WorkerLogDeliveryTypeDef(TypedDict):
cloudWatchLogs: NotRequired[CloudWatchLogsLogDeliveryTypeDef], # (1)
firehose: NotRequired[FirehoseLogDeliveryTypeDef], # (2)
s3: NotRequired[S3LogDeliveryTypeDef], # (3)
KafkaClusterDescriptionTypeDef#
# KafkaClusterDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import KafkaClusterDescriptionTypeDef
def get_value() -> KafkaClusterDescriptionTypeDef:
return {
"apacheKafkaCluster": ...,
}
# KafkaClusterDescriptionTypeDef definition
class KafkaClusterDescriptionTypeDef(TypedDict):
apacheKafkaCluster: NotRequired[ApacheKafkaClusterDescriptionTypeDef], # (1)
KafkaClusterTypeDef#
# KafkaClusterTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import KafkaClusterTypeDef
def get_value() -> KafkaClusterTypeDef:
return {
"apacheKafkaCluster": ...,
}
# KafkaClusterTypeDef definition
class KafkaClusterTypeDef(TypedDict):
apacheKafkaCluster: ApacheKafkaClusterTypeDef, # (1)
CapacityDescriptionTypeDef#
# CapacityDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CapacityDescriptionTypeDef
def get_value() -> CapacityDescriptionTypeDef:
return {
"autoScaling": ...,
}
# CapacityDescriptionTypeDef definition
class CapacityDescriptionTypeDef(TypedDict):
autoScaling: NotRequired[AutoScalingDescriptionTypeDef], # (1)
provisionedCapacity: NotRequired[ProvisionedCapacityDescriptionTypeDef], # (2)
CapacityTypeDef#
# CapacityTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CapacityTypeDef
def get_value() -> CapacityTypeDef:
return {
"autoScaling": ...,
}
# CapacityTypeDef definition
class CapacityTypeDef(TypedDict):
autoScaling: NotRequired[AutoScalingTypeDef], # (1)
provisionedCapacity: NotRequired[ProvisionedCapacityTypeDef], # (2)
CapacityUpdateTypeDef#
# CapacityUpdateTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CapacityUpdateTypeDef
def get_value() -> CapacityUpdateTypeDef:
return {
"autoScaling": ...,
}
# CapacityUpdateTypeDef definition
class CapacityUpdateTypeDef(TypedDict):
autoScaling: NotRequired[AutoScalingUpdateTypeDef], # (1)
provisionedCapacity: NotRequired[ProvisionedCapacityUpdateTypeDef], # (2)
ListWorkerConfigurationsResponseTypeDef#
# ListWorkerConfigurationsResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListWorkerConfigurationsResponseTypeDef
def get_value() -> ListWorkerConfigurationsResponseTypeDef:
return {
"nextToken": ...,
"workerConfigurations": ...,
"ResponseMetadata": ...,
}
# ListWorkerConfigurationsResponseTypeDef definition
class ListWorkerConfigurationsResponseTypeDef(TypedDict):
nextToken: str,
workerConfigurations: List[WorkerConfigurationSummaryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
CustomPluginRevisionSummaryTypeDef#
# CustomPluginRevisionSummaryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginRevisionSummaryTypeDef
def get_value() -> CustomPluginRevisionSummaryTypeDef:
return {
"contentType": ...,
}
# CustomPluginRevisionSummaryTypeDef definition
class CustomPluginRevisionSummaryTypeDef(TypedDict):
contentType: NotRequired[CustomPluginContentTypeType], # (1)
creationTime: NotRequired[datetime],
description: NotRequired[str],
fileDescription: NotRequired[CustomPluginFileDescriptionTypeDef], # (2)
location: NotRequired[CustomPluginLocationDescriptionTypeDef], # (3)
revision: NotRequired[int],
- See CustomPluginContentTypeType
- See CustomPluginFileDescriptionTypeDef
- See CustomPluginLocationDescriptionTypeDef
CreateCustomPluginRequestRequestTypeDef#
# CreateCustomPluginRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CreateCustomPluginRequestRequestTypeDef
def get_value() -> CreateCustomPluginRequestRequestTypeDef:
return {
"contentType": ...,
"location": ...,
"name": ...,
}
# CreateCustomPluginRequestRequestTypeDef definition
class CreateCustomPluginRequestRequestTypeDef(TypedDict):
contentType: CustomPluginContentTypeType, # (1)
location: CustomPluginLocationTypeDef, # (2)
name: str,
description: NotRequired[str],
LogDeliveryDescriptionTypeDef#
# LogDeliveryDescriptionTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import LogDeliveryDescriptionTypeDef
def get_value() -> LogDeliveryDescriptionTypeDef:
return {
"workerLogDelivery": ...,
}
# LogDeliveryDescriptionTypeDef definition
class LogDeliveryDescriptionTypeDef(TypedDict):
workerLogDelivery: NotRequired[WorkerLogDeliveryDescriptionTypeDef], # (1)
LogDeliveryTypeDef#
# LogDeliveryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import LogDeliveryTypeDef
def get_value() -> LogDeliveryTypeDef:
return {
"workerLogDelivery": ...,
}
# LogDeliveryTypeDef definition
class LogDeliveryTypeDef(TypedDict):
workerLogDelivery: WorkerLogDeliveryTypeDef, # (1)
UpdateConnectorRequestRequestTypeDef#
# UpdateConnectorRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import UpdateConnectorRequestRequestTypeDef
def get_value() -> UpdateConnectorRequestRequestTypeDef:
return {
"capacity": ...,
"connectorArn": ...,
"currentVersion": ...,
}
# UpdateConnectorRequestRequestTypeDef definition
class UpdateConnectorRequestRequestTypeDef(TypedDict):
capacity: CapacityUpdateTypeDef, # (1)
connectorArn: str,
currentVersion: str,
CustomPluginSummaryTypeDef#
# CustomPluginSummaryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CustomPluginSummaryTypeDef
def get_value() -> CustomPluginSummaryTypeDef:
return {
"creationTime": ...,
}
# CustomPluginSummaryTypeDef definition
class CustomPluginSummaryTypeDef(TypedDict):
creationTime: NotRequired[datetime],
customPluginArn: NotRequired[str],
customPluginState: NotRequired[CustomPluginStateType], # (1)
description: NotRequired[str],
latestRevision: NotRequired[CustomPluginRevisionSummaryTypeDef], # (2)
name: NotRequired[str],
DescribeCustomPluginResponseTypeDef#
# DescribeCustomPluginResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DescribeCustomPluginResponseTypeDef
def get_value() -> DescribeCustomPluginResponseTypeDef:
return {
"creationTime": ...,
"customPluginArn": ...,
"customPluginState": ...,
"description": ...,
"latestRevision": ...,
"name": ...,
"stateDescription": ...,
"ResponseMetadata": ...,
}
# DescribeCustomPluginResponseTypeDef definition
class DescribeCustomPluginResponseTypeDef(TypedDict):
creationTime: datetime,
customPluginArn: str,
customPluginState: CustomPluginStateType, # (1)
description: str,
latestRevision: CustomPluginRevisionSummaryTypeDef, # (2)
name: str,
stateDescription: StateDescriptionTypeDef, # (3)
ResponseMetadata: ResponseMetadataTypeDef, # (4)
- See CustomPluginStateType
- See CustomPluginRevisionSummaryTypeDef
- See StateDescriptionTypeDef
- See ResponseMetadataTypeDef
ConnectorSummaryTypeDef#
# ConnectorSummaryTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ConnectorSummaryTypeDef
def get_value() -> ConnectorSummaryTypeDef:
return {
"capacity": ...,
}
# ConnectorSummaryTypeDef definition
class ConnectorSummaryTypeDef(TypedDict):
capacity: NotRequired[CapacityDescriptionTypeDef], # (1)
connectorArn: NotRequired[str],
connectorDescription: NotRequired[str],
connectorName: NotRequired[str],
connectorState: NotRequired[ConnectorStateType], # (2)
creationTime: NotRequired[datetime],
currentVersion: NotRequired[str],
kafkaCluster: NotRequired[KafkaClusterDescriptionTypeDef], # (3)
kafkaClusterClientAuthentication: NotRequired[KafkaClusterClientAuthenticationDescriptionTypeDef], # (4)
kafkaClusterEncryptionInTransit: NotRequired[KafkaClusterEncryptionInTransitDescriptionTypeDef], # (5)
kafkaConnectVersion: NotRequired[str],
logDelivery: NotRequired[LogDeliveryDescriptionTypeDef], # (6)
plugins: NotRequired[List[PluginDescriptionTypeDef]], # (7)
serviceExecutionRoleArn: NotRequired[str],
workerConfiguration: NotRequired[WorkerConfigurationDescriptionTypeDef], # (8)
- See CapacityDescriptionTypeDef
- See ConnectorStateType
- See KafkaClusterDescriptionTypeDef
- See KafkaClusterClientAuthenticationDescriptionTypeDef
- See KafkaClusterEncryptionInTransitDescriptionTypeDef
- See LogDeliveryDescriptionTypeDef
- See PluginDescriptionTypeDef
- See WorkerConfigurationDescriptionTypeDef
DescribeConnectorResponseTypeDef#
# DescribeConnectorResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import DescribeConnectorResponseTypeDef
def get_value() -> DescribeConnectorResponseTypeDef:
return {
"capacity": ...,
"connectorArn": ...,
"connectorConfiguration": ...,
"connectorDescription": ...,
"connectorName": ...,
"connectorState": ...,
"creationTime": ...,
"currentVersion": ...,
"kafkaCluster": ...,
"kafkaClusterClientAuthentication": ...,
"kafkaClusterEncryptionInTransit": ...,
"kafkaConnectVersion": ...,
"logDelivery": ...,
"plugins": ...,
"serviceExecutionRoleArn": ...,
"stateDescription": ...,
"workerConfiguration": ...,
"ResponseMetadata": ...,
}
# DescribeConnectorResponseTypeDef definition
class DescribeConnectorResponseTypeDef(TypedDict):
capacity: CapacityDescriptionTypeDef, # (1)
connectorArn: str,
connectorConfiguration: Dict[str, str],
connectorDescription: str,
connectorName: str,
connectorState: ConnectorStateType, # (2)
creationTime: datetime,
currentVersion: str,
kafkaCluster: KafkaClusterDescriptionTypeDef, # (3)
kafkaClusterClientAuthentication: KafkaClusterClientAuthenticationDescriptionTypeDef, # (4)
kafkaClusterEncryptionInTransit: KafkaClusterEncryptionInTransitDescriptionTypeDef, # (5)
kafkaConnectVersion: str,
logDelivery: LogDeliveryDescriptionTypeDef, # (6)
plugins: List[PluginDescriptionTypeDef], # (7)
serviceExecutionRoleArn: str,
stateDescription: StateDescriptionTypeDef, # (8)
workerConfiguration: WorkerConfigurationDescriptionTypeDef, # (9)
ResponseMetadata: ResponseMetadataTypeDef, # (10)
- See CapacityDescriptionTypeDef
- See ConnectorStateType
- See KafkaClusterDescriptionTypeDef
- See KafkaClusterClientAuthenticationDescriptionTypeDef
- See KafkaClusterEncryptionInTransitDescriptionTypeDef
- See LogDeliveryDescriptionTypeDef
- See PluginDescriptionTypeDef
- See StateDescriptionTypeDef
- See WorkerConfigurationDescriptionTypeDef
- See ResponseMetadataTypeDef
CreateConnectorRequestRequestTypeDef#
# CreateConnectorRequestRequestTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import CreateConnectorRequestRequestTypeDef
def get_value() -> CreateConnectorRequestRequestTypeDef:
return {
"capacity": ...,
"connectorConfiguration": ...,
"connectorName": ...,
"kafkaCluster": ...,
"kafkaClusterClientAuthentication": ...,
"kafkaClusterEncryptionInTransit": ...,
"kafkaConnectVersion": ...,
"plugins": ...,
"serviceExecutionRoleArn": ...,
}
# CreateConnectorRequestRequestTypeDef definition
class CreateConnectorRequestRequestTypeDef(TypedDict):
capacity: CapacityTypeDef, # (1)
connectorConfiguration: Mapping[str, str],
connectorName: str,
kafkaCluster: KafkaClusterTypeDef, # (2)
kafkaClusterClientAuthentication: KafkaClusterClientAuthenticationTypeDef, # (3)
kafkaClusterEncryptionInTransit: KafkaClusterEncryptionInTransitTypeDef, # (4)
kafkaConnectVersion: str,
plugins: Sequence[PluginTypeDef], # (5)
serviceExecutionRoleArn: str,
connectorDescription: NotRequired[str],
logDelivery: NotRequired[LogDeliveryTypeDef], # (6)
workerConfiguration: NotRequired[WorkerConfigurationTypeDef], # (7)
- See CapacityTypeDef
- See KafkaClusterTypeDef
- See KafkaClusterClientAuthenticationTypeDef
- See KafkaClusterEncryptionInTransitTypeDef
- See PluginTypeDef
- See LogDeliveryTypeDef
- See WorkerConfigurationTypeDef
ListCustomPluginsResponseTypeDef#
# ListCustomPluginsResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListCustomPluginsResponseTypeDef
def get_value() -> ListCustomPluginsResponseTypeDef:
return {
"customPlugins": ...,
"nextToken": ...,
"ResponseMetadata": ...,
}
# ListCustomPluginsResponseTypeDef definition
class ListCustomPluginsResponseTypeDef(TypedDict):
customPlugins: List[CustomPluginSummaryTypeDef], # (1)
nextToken: str,
ResponseMetadata: ResponseMetadataTypeDef, # (2)
ListConnectorsResponseTypeDef#
# ListConnectorsResponseTypeDef usage example
from mypy_boto3_kafkaconnect.type_defs import ListConnectorsResponseTypeDef
def get_value() -> ListConnectorsResponseTypeDef:
return {
"connectors": ...,
"nextToken": ...,
"ResponseMetadata": ...,
}
# ListConnectorsResponseTypeDef definition
class ListConnectorsResponseTypeDef(TypedDict):
connectors: List[ConnectorSummaryTypeDef], # (1)
nextToken: str,
ResponseMetadata: ResponseMetadataTypeDef, # (2)