Skip to content

Kafkaconnect Classes

ApacheKafkaCluster

bootstrapServers

  • Type:
  • Required: Yes

vpc

  • Type:
  • Required: Yes

ApacheKafkaClusterDescription

bootstrapServers

  • Type: typing.Optional[str]

vpc

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.VpcDescription]

AutoScaling

maxWorkerCount

  • Type:
  • Required: Yes

mcuCount

  • Type:
  • Required: Yes

minWorkerCount

  • Type:
  • Required: Yes

scaleInPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ScaleInPolicy]

scaleOutPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ScaleOutPolicy]

AutoScalingDescription

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.kafkaconnect_classes.ScaleInPolicyDescription]

scaleOutPolicy

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ScaleOutPolicyDescription]

AutoScalingUpdate

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!

Capacity

autoScaling

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.AutoScaling]

provisionedCapacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ProvisionedCapacity]

CapacityDescription

autoScaling

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.AutoScalingDescription]

provisionedCapacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ProvisionedCapacityDescription]

CapacityUpdate

autoScaling

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.AutoScalingUpdate]

provisionedCapacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ProvisionedCapacityUpdate]

CloudWatchLogsLogDelivery

enabled

  • Type:
  • Required: Yes

logGroup

  • Type: typing.Optional[str]

CloudWatchLogsLogDeliveryDescription

enabled

  • Type: typing.Optional[bool]

logGroup

  • Type: typing.Optional[str]

ConnectorOperationStep

stepType

  • Type: typing.Optional[typing.Literal['FINALIZE_UPDATE', 'INITIALIZE_UPDATE', 'UPDATE_CONNECTOR_CONFIGURATION', 'UPDATE_WORKER_SETTING', 'VALIDATE_UPDATE']]

stepState

  • Type: typing.Optional[typing.Literal['CANCELLED', 'COMPLETED', 'FAILED', 'IN_PROGRESS', 'PENDING']]

ConnectorOperationSummary

connectorOperationArn

  • Type: typing.Optional[str]

connectorOperationType

  • Type: typing.Optional[typing.Literal['ISOLATE_CONNECTOR', 'RESTORE_CONNECTOR', 'UPDATE_CONNECTOR_CONFIGURATION', 'UPDATE_WORKER_SETTING']]

connectorOperationState

  • Type: typing.Optional[typing.Literal['PENDING', 'ROLLBACK_COMPLETE', 'ROLLBACK_FAILED', 'ROLLBACK_IN_PROGRESS', 'UPDATE_COMPLETE', 'UPDATE_FAILED', 'UPDATE_IN_PROGRESS']]

creationTime

  • Type: typing.Optional[datetime.datetime]

endTime

  • Type: typing.Optional[datetime.datetime]

ConnectorSummary

capacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CapacityDescription]

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.kafkaconnect_classes.KafkaClusterDescription]

kafkaClusterClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.KafkaClusterClientAuthenticationDescription]

kafkaClusterEncryptionInTransit

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.KafkaClusterEncryptionInTransitDescription]

kafkaConnectVersion

  • Type: typing.Optional[str]

logDelivery

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.LogDeliveryDescription]

plugins

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

serviceExecutionRoleArn

  • Type: typing.Optional[str]

workerConfiguration

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.WorkerConfigurationDescription]

CreateConnectorRequest

capacity

  • Type:
  • Required: Yes

connectorConfiguration

  • Type: typing.Dict[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.List[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.Plugin]
  • Required: Yes

serviceExecutionRoleArn

  • Type:
  • Required: Yes

connectorDescription

  • Type: typing.Optional[str]

logDelivery

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.LogDelivery]

workerConfiguration

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.WorkerConfiguration]

tags

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

CreateConnectorResponse

connectorArn

  • Type:
  • Required: Yes

connectorName

  • Type:
  • Required: Yes

connectorState

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

ResponseMetadata

  • Type:
  • Required: Yes

CreateCustomPluginRequest

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.Dict[str, str]]

CreateCustomPluginResponse

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

CreateWorkerConfigurationRequest

name

  • Type:
  • Required: Yes

propertiesFileContent

  • Type:
  • Required: Yes

description

  • Type: typing.Optional[str]

tags

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

CreateWorkerConfigurationResponse

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

CustomPlugin

customPluginArn

  • Type:
  • Required: Yes

revision

  • Type:
  • Required: Yes

CustomPluginDescription

customPluginArn

  • Type: typing.Optional[str]

revision

  • Type: typing.Optional[int]

CustomPluginFileDescription

fileMd5

  • Type: typing.Optional[str]

fileSize

  • Type: typing.Optional[int]

CustomPluginLocation

s3Location

  • Type:
  • Required: Yes

CustomPluginLocationDescription

s3Location

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.S3LocationDescription]

CustomPluginRevisionSummary

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.kafkaconnect_classes.CustomPluginFileDescription]

location

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CustomPluginLocationDescription]

revision

  • Type: typing.Optional[int]

CustomPluginSummary

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.kafkaconnect_classes.CustomPluginRevisionSummary]

name

  • Type: typing.Optional[str]

DeleteConnectorRequest

connectorArn

  • Type:
  • Required: Yes

currentVersion

  • Type: typing.Optional[str]

DeleteConnectorResponse

connectorArn

  • Type:
  • Required: Yes

connectorState

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteCustomPluginRequest

customPluginArn

  • Type:
  • Required: Yes

DeleteCustomPluginResponse

customPluginArn

  • Type:
  • Required: Yes

customPluginState

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteWorkerConfigurationRequest

workerConfigurationArn

  • Type:
  • Required: Yes

DeleteWorkerConfigurationResponse

workerConfigurationArn

  • Type:
  • Required: Yes

workerConfigurationState

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

ResponseMetadata

  • Type:
  • Required: Yes

DescribeConnectorOperationRequest

connectorOperationArn

  • Type:
  • Required: Yes

DescribeConnectorOperationResponse

connectorArn

  • Type:
  • Required: Yes

connectorOperationArn

  • Type:
  • Required: Yes

connectorOperationState

  • Type: typing.Literal['PENDING', 'ROLLBACK_COMPLETE', 'ROLLBACK_FAILED', 'ROLLBACK_IN_PROGRESS', 'UPDATE_COMPLETE', 'UPDATE_FAILED', 'UPDATE_IN_PROGRESS']
  • Required: Yes

connectorOperationType

  • Type: typing.Literal['ISOLATE_CONNECTOR', 'RESTORE_CONNECTOR', 'UPDATE_CONNECTOR_CONFIGURATION', 'UPDATE_WORKER_SETTING']
  • Required: Yes

operationSteps

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

originWorkerSetting

  • Type:
  • Required: Yes

originConnectorConfiguration

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

targetWorkerSetting

  • Type:
  • Required: Yes

targetConnectorConfiguration

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

errorInfo

  • Type:
  • Required: Yes

creationTime

  • Type:
  • Required: Yes

endTime

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeConnectorRequest

connectorArn

  • Type:
  • Required: Yes

DescribeConnectorResponse

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.kafkaconnect_classes.PluginDescription]
  • Required: Yes

serviceExecutionRoleArn

  • Type:
  • Required: Yes

workerConfiguration

  • Type:
  • Required: Yes

stateDescription

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeCustomPluginRequest

customPluginArn

  • Type:
  • Required: Yes

DescribeCustomPluginResponse

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

DescribeWorkerConfigurationRequest

workerConfigurationArn

  • Type:
  • Required: Yes

DescribeWorkerConfigurationResponse

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

FirehoseLogDelivery

enabled

  • Type:
  • Required: Yes

deliveryStream

  • Type: typing.Optional[str]

FirehoseLogDeliveryDescription

deliveryStream

  • Type: typing.Optional[str]

enabled

  • Type: typing.Optional[bool]

KafkaCluster

apacheKafkaCluster

  • Type:
  • Required: Yes

KafkaClusterClientAuthentication

authenticationType

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

KafkaClusterClientAuthenticationDescription

authenticationType

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

KafkaClusterDescription

apacheKafkaCluster

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.ApacheKafkaClusterDescription]

KafkaClusterEncryptionInTransit

encryptionType

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

KafkaClusterEncryptionInTransitDescription

encryptionType

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

ListConnectorOperationsRequest

connectorArn

  • Type:
  • Required: Yes

maxResults

  • Type: typing.Optional[int]

nextToken

  • Type: typing.Optional[str]

ListConnectorOperationsRequestPaginate

connectorArn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.PaginatorConfig]

ListConnectorOperationsResponse

connectorOperations

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

ResponseMetadata

  • Type:
  • Required: Yes

nextToken

  • Type: typing.Optional[str]

ListConnectorsRequest

connectorNamePrefix

  • Type: typing.Optional[str]

maxResults

  • Type: typing.Optional[int]

nextToken

  • Type: typing.Optional[str]

ListConnectorsRequestPaginate

connectorNamePrefix

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.PaginatorConfig]

ListConnectorsResponse

connectors

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

ResponseMetadata

  • Type:
  • Required: Yes

nextToken

  • Type: typing.Optional[str]

ListCustomPluginsRequest

maxResults

  • Type: typing.Optional[int]

nextToken

  • Type: typing.Optional[str]

namePrefix

  • Type: typing.Optional[str]

ListCustomPluginsRequestPaginate

namePrefix

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.PaginatorConfig]

ListCustomPluginsResponse

customPlugins

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

ResponseMetadata

  • Type:
  • Required: Yes

nextToken

  • Type: typing.Optional[str]

ListTagsForResourceRequest

resourceArn

  • Type:
  • Required: Yes

ListTagsForResourceResponse

tags

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

ResponseMetadata

  • Type:
  • Required: Yes

ListWorkerConfigurationsRequest

maxResults

  • Type: typing.Optional[int]

nextToken

  • Type: typing.Optional[str]

namePrefix

  • Type: typing.Optional[str]

ListWorkerConfigurationsRequestPaginate

namePrefix

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.PaginatorConfig]

ListWorkerConfigurationsResponse

workerConfigurations

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

ResponseMetadata

  • Type:
  • Required: Yes

nextToken

  • Type: typing.Optional[str]

LogDelivery

workerLogDelivery

  • Type:
  • Required: Yes

LogDeliveryDescription

workerLogDelivery

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.WorkerLogDeliveryDescription]

PaginatorConfig

MaxItems

  • Type: typing.Optional[int]

PageSize

  • Type: typing.Optional[int]

StartingToken

  • Type: typing.Optional[str]

Plugin

customPlugin

  • Type:
  • Required: Yes

PluginDescription

customPlugin

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CustomPluginDescription]

ProvisionedCapacity

mcuCount

  • Type:
  • Required: Yes

workerCount

  • Type:
  • Required: Yes

ProvisionedCapacityDescription

mcuCount

  • Type: typing.Optional[int]

workerCount

  • Type: typing.Optional[int]

ProvisionedCapacityUpdate

mcuCount

  • Type:
  • Required: Yes

workerCount

  • Type:
  • Required: Yes

ResponseMetadata

RequestId

  • Type:
  • Required: Yes

HTTPStatusCode

  • Type:
  • Required: Yes

HTTPHeaders

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

RetryAttempts

  • Type:
  • Required: Yes

HostId

  • Type: typing.Optional[str]

S3Location

bucketArn

  • Type:
  • Required: Yes

fileKey

  • Type:
  • Required: Yes

objectVersion

  • Type: typing.Optional[str]

S3LocationDescription

bucketArn

  • Type: typing.Optional[str]

fileKey

  • Type: typing.Optional[str]

objectVersion

  • Type: typing.Optional[str]

S3LogDelivery

enabled

  • Type:
  • Required: Yes

bucket

  • Type: typing.Optional[str]

prefix

  • Type: typing.Optional[str]

S3LogDeliveryDescription

bucket

  • Type: typing.Optional[str]

enabled

  • Type: typing.Optional[bool]

prefix

  • Type: typing.Optional[str]

ScaleInPolicy

cpuUtilizationPercentage

  • Type:
  • Required: Yes

ScaleInPolicyDescription

cpuUtilizationPercentage

  • Type: typing.Optional[int]

ScaleInPolicyUpdate

cpuUtilizationPercentage

  • Type:
  • Required: Yes

ScaleOutPolicy

cpuUtilizationPercentage

  • Type:
  • Required: Yes

ScaleOutPolicyDescription

cpuUtilizationPercentage

  • Type: typing.Optional[int]

ScaleOutPolicyUpdate

cpuUtilizationPercentage

  • Type:
  • Required: Yes

StateDescription

code

  • Type: typing.Optional[str]

message

  • Type: typing.Optional[str]

TagResourceRequest

resourceArn

  • Type:
  • Required: Yes

tags

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

UntagResourceRequest

resourceArn

  • Type:
  • Required: Yes

tagKeys

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

UpdateConnectorRequest

connectorArn

  • Type:
  • Required: Yes

currentVersion

  • Type:
  • Required: Yes

capacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CapacityUpdate]

connectorConfiguration

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

UpdateConnectorResponse

connectorArn

  • Type:
  • Required: Yes

connectorState

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

connectorOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

Vpc

subnets

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

securityGroups

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

VpcDescription

securityGroups

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

subnets

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

WorkerConfiguration

revision

  • Type:
  • Required: Yes

workerConfigurationArn

  • Type:
  • Required: Yes

WorkerConfigurationDescription

revision

  • Type: typing.Optional[int]

workerConfigurationArn

  • Type: typing.Optional[str]

WorkerConfigurationRevisionDescription

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

propertiesFileContent

  • Type: typing.Optional[str]

revision

  • Type: typing.Optional[int]

WorkerConfigurationRevisionSummary

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

revision

  • Type: typing.Optional[int]

WorkerConfigurationSummary

creationTime

  • Type: typing.Optional[datetime.datetime]

description

  • Type: typing.Optional[str]

latestRevision

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.WorkerConfigurationRevisionSummary]

name

  • Type: typing.Optional[str]

workerConfigurationArn

  • Type: typing.Optional[str]

workerConfigurationState

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

WorkerLogDelivery

cloudWatchLogs

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CloudWatchLogsLogDelivery]

firehose

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.FirehoseLogDelivery]

s3

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.S3LogDelivery]

WorkerLogDeliveryDescription

cloudWatchLogs

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CloudWatchLogsLogDeliveryDescription]

firehose

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.FirehoseLogDeliveryDescription]

s3

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.S3LogDeliveryDescription]

WorkerSetting

capacity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafkaconnect.kafkaconnect_classes.CapacityDescription]