Skip to content

Kafkaconnect Classes

ApacheKafkaClusterDescriptionTypeDef

bootstrapServers

  • Type: typing.Optional[str]

vpc

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.VpcDescriptionTypeDef]

ApacheKafkaClusterTypeDef

bootstrapServers

  • Type:
  • Required: Yes

vpc

  • Type:
  • Required: Yes

AutoScalingDescriptionTypeDef

maxWorkerCount

  • Type: typing.Optional[int]

mcuCount

  • Type: typing.Optional[int]

minWorkerCount

  • Type: typing.Optional[int]

scaleInPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ScaleInPolicyDescriptionTypeDef]

scaleOutPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ScaleOutPolicyDescriptionTypeDef]

AutoScalingTypeDef

maxWorkerCount

  • Type:
  • Required: Yes

mcuCount

  • Type:
  • Required: Yes

minWorkerCount

  • Type:
  • Required: Yes

scaleInPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ScaleInPolicyTypeDef]

scaleOutPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ScaleOutPolicyTypeDef]

AutoScalingUpdateTypeDef

maxWorkerCount

  • Type:
  • Required: Yes

mcuCount

  • Type:
  • Required: Yes

minWorkerCount

  • Type:
  • Required: Yes

scaleInPolicy

  • Type:
  • Required: Yes

scaleOutPolicy

  • Type:
  • Required: Yes

BaseValidatorModel

Oops! This Pydantic model is currently empty. Stay tuned!

CapacityDescriptionTypeDef

autoScaling

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.AutoScalingDescriptionTypeDef]

provisionedCapacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ProvisionedCapacityDescriptionTypeDef]

CapacityTypeDef

autoScaling

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.AutoScalingTypeDef]

provisionedCapacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ProvisionedCapacityTypeDef]

CapacityUpdateTypeDef

autoScaling

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.AutoScalingUpdateTypeDef]

provisionedCapacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ProvisionedCapacityUpdateTypeDef]

CloudWatchLogsLogDeliveryDescriptionTypeDef

enabled

  • Type: typing.Optional[bool]

logGroup

  • Type: typing.Optional[str]

CloudWatchLogsLogDeliveryTypeDef

enabled

  • Type:
  • Required: Yes

logGroup

  • Type: typing.Optional[str]

ConnectorSummaryTypeDef

capacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CapacityDescriptionTypeDef]

connectorArn

  • Type: typing.Optional[str]

connectorDescription

  • Type: typing.Optional[str]

connectorName

  • Type: typing.Optional[str]

connectorState

  • Type: typing.Optional[typing.Literal['CREATING', 'DELETING', 'FAILED', 'RUNNING', 'UPDATING']]

creationTime

  • Type: typing.Optional[datetime.datetime]

currentVersion

  • Type: typing.Optional[str]

kafkaCluster

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.KafkaClusterDescriptionTypeDef]

kafkaClusterClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.KafkaClusterClientAuthenticationDescriptionTypeDef]

kafkaClusterEncryptionInTransit

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.KafkaClusterEncryptionInTransitDescriptionTypeDef]

kafkaConnectVersion

  • Type: typing.Optional[str]

logDelivery

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.LogDeliveryDescriptionTypeDef]

plugins

  • Type: typing.Optional[typing.List[aws_resource_validator.pydantic_models.kafkaconnect_classes.PluginDescriptionTypeDef]]

serviceExecutionRoleArn

  • Type: typing.Optional[str]

workerConfiguration

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.WorkerConfigurationDescriptionTypeDef]

CreateConnectorRequestRequestTypeDef

capacity

  • Type:
  • Required: Yes

connectorConfiguration

  • Type: typing.Mapping[str, str]
  • Required: Yes

connectorName

  • Type:
  • Required: Yes

kafkaCluster

  • Type:
  • Required: Yes

kafkaClusterClientAuthentication

  • Type:
  • Required: Yes

kafkaClusterEncryptionInTransit

  • Type:
  • Required: Yes

kafkaConnectVersion

  • Type:
  • Required: Yes

plugins

  • Type: typing.Sequence[aws_resource_validator.pydantic_models.kafkaconnect_classes.PluginTypeDef]
  • Required: Yes

serviceExecutionRoleArn

  • Type:
  • Required: Yes

connectorDescription

  • Type: typing.Optional[str]

logDelivery

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.LogDeliveryTypeDef]

tags

  • Type: typing.Optional[typing.Mapping[str, str]]

workerConfiguration

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.WorkerConfigurationTypeDef]

CreateConnectorResponseTypeDef

connectorArn

  • Type:
  • Required: Yes

connectorName

  • Type:
  • Required: Yes

connectorState

  • Type: typing.Literal['CREATING', 'DELETING', 'FAILED', 'RUNNING', 'UPDATING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

CreateCustomPluginRequestRequestTypeDef

contentType

  • Type: typing.Literal['JAR', 'ZIP']
  • Required: Yes

location

  • Type:
  • Required: Yes

name

  • Type:
  • Required: Yes

description

  • Type: typing.Optional[str]

tags

  • Type: typing.Optional[typing.Mapping[str, str]]

CreateCustomPluginResponseTypeDef

customPluginArn

  • Type:
  • Required: Yes

customPluginState

  • Type: typing.Literal['ACTIVE', 'CREATE_FAILED', 'CREATING', 'DELETING', 'UPDATE_FAILED', 'UPDATING']
  • Required: Yes

name

  • Type:
  • Required: Yes

revision

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

CreateWorkerConfigurationRequestRequestTypeDef

name

  • Type:
  • Required: Yes

propertiesFileContent

  • Type:
  • Required: Yes

description

  • Type: typing.Optional[str]

tags

  • Type: typing.Optional[typing.Mapping[str, str]]

CreateWorkerConfigurationResponseTypeDef

creationTime

  • Type:
  • Required: Yes

latestRevision

  • Type:
  • Required: Yes

name

  • Type:
  • Required: Yes

workerConfigurationArn

  • Type:
  • Required: Yes

workerConfigurationState

  • Type: typing.Literal['ACTIVE', 'DELETING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

CustomPluginDescriptionTypeDef

customPluginArn

  • Type: typing.Optional[str]

revision

  • Type: typing.Optional[int]

CustomPluginFileDescriptionTypeDef

fileMd5

  • Type: typing.Optional[str]

fileSize

  • Type: typing.Optional[int]

CustomPluginLocationDescriptionTypeDef

s3Location

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.S3LocationDescriptionTypeDef]

CustomPluginLocationTypeDef

s3Location

  • Type:
  • Required: Yes

CustomPluginRevisionSummaryTypeDef

contentType

  • Type: typing.Optional[typing.Literal['JAR', 'ZIP']]

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

fileDescription

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CustomPluginFileDescriptionTypeDef]

location

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CustomPluginLocationDescriptionTypeDef]

revision

  • Type: typing.Optional[int]

CustomPluginSummaryTypeDef

creationTime

  • Type: typing.Optional[datetime.datetime]

customPluginArn

  • Type: typing.Optional[str]

customPluginState

  • Type: typing.Optional[typing.Literal['ACTIVE', 'CREATE_FAILED', 'CREATING', 'DELETING', 'UPDATE_FAILED', 'UPDATING']]

description

  • Type: typing.Optional[str]

latestRevision

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CustomPluginRevisionSummaryTypeDef]

name

  • Type: typing.Optional[str]

CustomPluginTypeDef

customPluginArn

  • Type:
  • Required: Yes

revision

  • Type:
  • Required: Yes

DeleteConnectorRequestRequestTypeDef

connectorArn

  • Type:
  • Required: Yes

currentVersion

  • Type: typing.Optional[str]

DeleteConnectorResponseTypeDef

connectorArn

  • Type:
  • Required: Yes

connectorState

  • Type: typing.Literal['CREATING', 'DELETING', 'FAILED', 'RUNNING', 'UPDATING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DeleteCustomPluginRequestRequestTypeDef

customPluginArn

  • Type:
  • Required: Yes

DeleteCustomPluginResponseTypeDef

customPluginArn

  • Type:
  • Required: Yes

customPluginState

  • Type: typing.Literal['ACTIVE', 'CREATE_FAILED', 'CREATING', 'DELETING', 'UPDATE_FAILED', 'UPDATING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DeleteWorkerConfigurationRequestRequestTypeDef

workerConfigurationArn

  • Type:
  • Required: Yes

DeleteWorkerConfigurationResponseTypeDef

workerConfigurationArn

  • Type:
  • Required: Yes

workerConfigurationState

  • Type: typing.Literal['ACTIVE', 'DELETING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeConnectorRequestRequestTypeDef

connectorArn

  • Type:
  • Required: Yes

DescribeConnectorResponseTypeDef

capacity

  • Type:
  • Required: Yes

connectorArn

  • Type:
  • Required: Yes

connectorConfiguration

  • Type: typing.Dict[str, str]
  • Required: Yes

connectorDescription

  • Type:
  • Required: Yes

connectorName

  • Type:
  • Required: Yes

connectorState

  • Type: typing.Literal['CREATING', 'DELETING', 'FAILED', 'RUNNING', 'UPDATING']
  • Required: Yes

creationTime

  • Type:
  • Required: Yes

currentVersion

  • Type:
  • Required: Yes

kafkaCluster

  • Type:
  • Required: Yes

kafkaClusterClientAuthentication

  • Type:
  • Required: Yes

kafkaClusterEncryptionInTransit

  • Type:
  • Required: Yes

kafkaConnectVersion

  • Type:
  • Required: Yes

logDelivery

  • Type:
  • Required: Yes

plugins

  • Type: typing.List[aws_resource_validator.pydantic_models.kafkaconnect_classes.PluginDescriptionTypeDef]
  • Required: Yes

serviceExecutionRoleArn

  • Type:
  • Required: Yes

stateDescription

  • Type:
  • Required: Yes

workerConfiguration

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeCustomPluginRequestRequestTypeDef

customPluginArn

  • Type:
  • Required: Yes

DescribeCustomPluginResponseTypeDef

creationTime

  • Type:
  • Required: Yes

customPluginArn

  • Type:
  • Required: Yes

customPluginState

  • Type: typing.Literal['ACTIVE', 'CREATE_FAILED', 'CREATING', 'DELETING', 'UPDATE_FAILED', 'UPDATING']
  • Required: Yes

description

  • Type:
  • Required: Yes

latestRevision

  • Type:
  • Required: Yes

name

  • Type:
  • Required: Yes

stateDescription

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeWorkerConfigurationRequestRequestTypeDef

workerConfigurationArn

  • Type:
  • Required: Yes

DescribeWorkerConfigurationResponseTypeDef

creationTime

  • Type:
  • Required: Yes

description

  • Type:
  • Required: Yes

latestRevision

  • Type:
  • Required: Yes

name

  • Type:
  • Required: Yes

workerConfigurationArn

  • Type:
  • Required: Yes

workerConfigurationState

  • Type: typing.Literal['ACTIVE', 'DELETING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

FirehoseLogDeliveryDescriptionTypeDef

deliveryStream

  • Type: typing.Optional[str]

enabled

  • Type: typing.Optional[bool]

FirehoseLogDeliveryTypeDef

enabled

  • Type:
  • Required: Yes

deliveryStream

  • Type: typing.Optional[str]

KafkaClusterClientAuthenticationDescriptionTypeDef

authenticationType

  • Type: typing.Optional[typing.Literal['IAM', 'NONE']]

KafkaClusterClientAuthenticationTypeDef

authenticationType

  • Type: typing.Literal['IAM', 'NONE']
  • Required: Yes

KafkaClusterDescriptionTypeDef

apacheKafkaCluster

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.ApacheKafkaClusterDescriptionTypeDef]

KafkaClusterEncryptionInTransitDescriptionTypeDef

encryptionType

  • Type: typing.Optional[typing.Literal['PLAINTEXT', 'TLS']]

KafkaClusterEncryptionInTransitTypeDef

encryptionType

  • Type: typing.Literal['PLAINTEXT', 'TLS']
  • Required: Yes

KafkaClusterTypeDef

apacheKafkaCluster

  • Type:
  • Required: Yes

ListConnectorsRequestListConnectorsPaginateTypeDef

connectorNamePrefix

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.PaginatorConfigTypeDef]

ListConnectorsRequestRequestTypeDef

connectorNamePrefix

  • Type: typing.Optional[str]

maxResults

  • Type: typing.Optional[int]

nextToken

  • Type: typing.Optional[str]

ListConnectorsResponseTypeDef

connectors

  • Type: typing.List[aws_resource_validator.pydantic_models.kafkaconnect_classes.ConnectorSummaryTypeDef]
  • Required: Yes

nextToken

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

ListCustomPluginsRequestListCustomPluginsPaginateTypeDef

namePrefix

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.PaginatorConfigTypeDef]

ListCustomPluginsRequestRequestTypeDef

maxResults

  • Type: typing.Optional[int]

namePrefix

  • Type: typing.Optional[str]

nextToken

  • Type: typing.Optional[str]

ListCustomPluginsResponseTypeDef

customPlugins

  • Type: typing.List[aws_resource_validator.pydantic_models.kafkaconnect_classes.CustomPluginSummaryTypeDef]
  • Required: Yes

nextToken

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

ListTagsForResourceRequestRequestTypeDef

resourceArn

  • Type:
  • Required: Yes

ListTagsForResourceResponseTypeDef

tags

  • Type: typing.Dict[str, str]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

ListWorkerConfigurationsRequestListWorkerConfigurationsPaginateTypeDef

namePrefix

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.PaginatorConfigTypeDef]

ListWorkerConfigurationsRequestRequestTypeDef

maxResults

  • Type: typing.Optional[int]

namePrefix

  • Type: typing.Optional[str]

nextToken

  • Type: typing.Optional[str]

ListWorkerConfigurationsResponseTypeDef

nextToken

  • Type:
  • Required: Yes

workerConfigurations

  • Type: typing.List[aws_resource_validator.pydantic_models.kafkaconnect_classes.WorkerConfigurationSummaryTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

LogDeliveryDescriptionTypeDef

workerLogDelivery

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.WorkerLogDeliveryDescriptionTypeDef]

LogDeliveryTypeDef

workerLogDelivery

  • Type:
  • Required: Yes

PaginatorConfigTypeDef

MaxItems

  • Type: typing.Optional[int]

PageSize

  • Type: typing.Optional[int]

StartingToken

  • Type: typing.Optional[str]

PluginDescriptionTypeDef

customPlugin

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CustomPluginDescriptionTypeDef]

PluginTypeDef

customPlugin

  • Type:
  • Required: Yes

ProvisionedCapacityDescriptionTypeDef

mcuCount

  • Type: typing.Optional[int]

workerCount

  • Type: typing.Optional[int]

ProvisionedCapacityTypeDef

mcuCount

  • Type:
  • Required: Yes

workerCount

  • Type:
  • Required: Yes

ProvisionedCapacityUpdateTypeDef

mcuCount

  • Type:
  • Required: Yes

workerCount

  • Type:
  • Required: Yes

ResponseMetadataTypeDef

RequestId

  • Type:
  • Required: Yes

HostId

  • Type:
  • Required: Yes

HTTPStatusCode

  • Type:
  • Required: Yes

HTTPHeaders

  • Type: typing.Dict[str, str]
  • Required: Yes

RetryAttempts

  • Type:
  • Required: Yes

S3LocationDescriptionTypeDef

bucketArn

  • Type: typing.Optional[str]

fileKey

  • Type: typing.Optional[str]

objectVersion

  • Type: typing.Optional[str]

S3LocationTypeDef

bucketArn

  • Type:
  • Required: Yes

fileKey

  • Type:
  • Required: Yes

objectVersion

  • Type: typing.Optional[str]

S3LogDeliveryDescriptionTypeDef

bucket

  • Type: typing.Optional[str]

enabled

  • Type: typing.Optional[bool]

prefix

  • Type: typing.Optional[str]

S3LogDeliveryTypeDef

enabled

  • Type:
  • Required: Yes

bucket

  • Type: typing.Optional[str]

prefix

  • Type: typing.Optional[str]

ScaleInPolicyDescriptionTypeDef

cpuUtilizationPercentage

  • Type: typing.Optional[int]

ScaleInPolicyTypeDef

cpuUtilizationPercentage

  • Type:
  • Required: Yes

ScaleInPolicyUpdateTypeDef

cpuUtilizationPercentage

  • Type:
  • Required: Yes

ScaleOutPolicyDescriptionTypeDef

cpuUtilizationPercentage

  • Type: typing.Optional[int]

ScaleOutPolicyTypeDef

cpuUtilizationPercentage

  • Type:
  • Required: Yes

ScaleOutPolicyUpdateTypeDef

cpuUtilizationPercentage

  • Type:
  • Required: Yes

StateDescriptionTypeDef

code

  • Type: typing.Optional[str]

message

  • Type: typing.Optional[str]

TagResourceRequestRequestTypeDef

resourceArn

  • Type:
  • Required: Yes

tags

  • Type: typing.Mapping[str, str]
  • Required: Yes

UntagResourceRequestRequestTypeDef

resourceArn

  • Type:
  • Required: Yes

tagKeys

  • Type: typing.Sequence[str]
  • Required: Yes

UpdateConnectorRequestRequestTypeDef

capacity

  • Type:
  • Required: Yes

connectorArn

  • Type:
  • Required: Yes

currentVersion

  • Type:
  • Required: Yes

UpdateConnectorResponseTypeDef

connectorArn

  • Type:
  • Required: Yes

connectorState

  • Type: typing.Literal['CREATING', 'DELETING', 'FAILED', 'RUNNING', 'UPDATING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

VpcDescriptionTypeDef

securityGroups

  • Type: typing.Optional[typing.List[str]]

subnets

  • Type: typing.Optional[typing.List[str]]

VpcTypeDef

subnets

  • Type: typing.Sequence[str]
  • Required: Yes

securityGroups

  • Type: typing.Optional[typing.Sequence[str]]

WorkerConfigurationDescriptionTypeDef

revision

  • Type: typing.Optional[int]

workerConfigurationArn

  • Type: typing.Optional[str]

WorkerConfigurationRevisionDescriptionTypeDef

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

propertiesFileContent

  • Type: typing.Optional[str]

revision

  • Type: typing.Optional[int]

WorkerConfigurationRevisionSummaryTypeDef

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

revision

  • Type: typing.Optional[int]

WorkerConfigurationSummaryTypeDef

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

latestRevision

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.WorkerConfigurationRevisionSummaryTypeDef]

name

  • Type: typing.Optional[str]

workerConfigurationArn

  • Type: typing.Optional[str]

workerConfigurationState

  • Type: typing.Optional[typing.Literal['ACTIVE', 'DELETING']]

WorkerConfigurationTypeDef

revision

  • Type:
  • Required: Yes

workerConfigurationArn

  • Type:
  • Required: Yes

WorkerLogDeliveryDescriptionTypeDef

cloudWatchLogs

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CloudWatchLogsLogDeliveryDescriptionTypeDef]

firehose

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.FirehoseLogDeliveryDescriptionTypeDef]

s3

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.S3LogDeliveryDescriptionTypeDef]

WorkerLogDeliveryTypeDef

cloudWatchLogs

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.CloudWatchLogsLogDeliveryTypeDef]

firehose

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.FirehoseLogDeliveryTypeDef]

s3

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect_classes.S3LogDeliveryTypeDef]