Skip to content

Kafka Classes

AmazonMskClusterTypeDef

MskClusterArn

  • Type:
  • Required: Yes

BaseValidatorModel

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

BatchAssociateScramSecretRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

SecretArnList

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

BatchAssociateScramSecretResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

UnprocessedScramSecrets

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.UnprocessedScramSecretTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

BatchDisassociateScramSecretRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

SecretArnList

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

BatchDisassociateScramSecretResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

UnprocessedScramSecrets

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.UnprocessedScramSecretTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

BrokerCountUpdateInfoTypeDef

CreatedBrokerIds

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

DeletedBrokerIds

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

BrokerEBSVolumeInfoTypeDef

KafkaBrokerNodeId

  • Type:
  • Required: Yes

ProvisionedThroughput

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ProvisionedThroughputTypeDef]

VolumeSizeGB

  • Type: typing.Optional[int]

BrokerLogsTypeDef

CloudWatchLogs

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.CloudWatchLogsTypeDef]

Firehose

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.FirehoseTypeDef]

S3

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.S3TypeDef]

BrokerNodeGroupInfoExtraOutputTypeDef

ClientSubnets

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

InstanceType

  • Type:
  • Required: Yes

BrokerAZDistribution

  • Type: typing.Optional[typing.Literal['DEFAULT']]

SecurityGroups

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

StorageInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.StorageInfoTypeDef]

ConnectivityInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConnectivityInfoTypeDef]

ZoneIds

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

BrokerNodeGroupInfoOutputTypeDef

ClientSubnets

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

InstanceType

  • Type:
  • Required: Yes

BrokerAZDistribution

  • Type: typing.Optional[typing.Literal['DEFAULT']]

SecurityGroups

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

StorageInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.StorageInfoTypeDef]

ConnectivityInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConnectivityInfoTypeDef]

ZoneIds

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

BrokerNodeGroupInfoTypeDef

ClientSubnets

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

InstanceType

  • Type:
  • Required: Yes

BrokerAZDistribution

  • Type: typing.Optional[typing.Literal['DEFAULT']]

SecurityGroups

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

StorageInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.StorageInfoTypeDef]

ConnectivityInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConnectivityInfoTypeDef]

ZoneIds

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

BrokerNodeInfoTypeDef

AttachedENIId

  • Type: typing.Optional[str]

BrokerId

  • Type: typing.Optional[float]

ClientSubnet

  • Type: typing.Optional[str]

ClientVpcIpAddress

  • Type: typing.Optional[str]

CurrentBrokerSoftwareInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.BrokerSoftwareInfoTypeDef]

Endpoints

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

BrokerSoftwareInfoTypeDef

ConfigurationArn

  • Type: typing.Optional[str]

ConfigurationRevision

  • Type: typing.Optional[int]

KafkaVersion

  • Type: typing.Optional[str]

ClientAuthenticationExtraOutputTypeDef

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.SaslTypeDef]

Tls

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.TlsExtraOutputTypeDef]

Unauthenticated

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.UnauthenticatedTypeDef]

ClientAuthenticationOutputTypeDef

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.SaslTypeDef]

Tls

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.TlsOutputTypeDef]

Unauthenticated

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.UnauthenticatedTypeDef]

ClientAuthenticationTypeDef

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.SaslTypeDef]

Tls

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.TlsTypeDef]

Unauthenticated

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.UnauthenticatedTypeDef]

ClientVpcConnectionTypeDef

VpcConnectionArn

  • Type:
  • Required: Yes

Authentication

  • Type: typing.Optional[str]

CreationTime

  • Type: typing.Optional[datetime.datetime]

State

  • Type: typing.Optional[typing.Literal['AVAILABLE', 'CREATING', 'DEACTIVATING', 'DELETING', 'FAILED', 'INACTIVE', 'REJECTED', 'REJECTING']]

Owner

  • Type: typing.Optional[str]

CloudWatchLogsTypeDef

Enabled

  • Type:
  • Required: Yes

LogGroup

  • Type: typing.Optional[str]

ClusterInfoTypeDef

ActiveOperationArn

  • Type: typing.Optional[str]

BrokerNodeGroupInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.BrokerNodeGroupInfoOutputTypeDef]

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClientAuthenticationOutputTypeDef]

ClusterArn

  • Type: typing.Optional[str]

ClusterName

  • Type: typing.Optional[str]

CreationTime

  • Type: typing.Optional[datetime.datetime]

CurrentBrokerSoftwareInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.BrokerSoftwareInfoTypeDef]

CurrentVersion

  • Type: typing.Optional[str]

EncryptionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInfoTypeDef]

EnhancedMonitoring

  • Type: typing.Optional[typing.Literal['DEFAULT', 'PER_BROKER', 'PER_TOPIC_PER_BROKER', 'PER_TOPIC_PER_PARTITION']]

OpenMonitoring

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.OpenMonitoringTypeDef]

LoggingInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.LoggingInfoTypeDef]

NumberOfBrokerNodes

  • Type: typing.Optional[int]

State

  • Type: typing.Optional[typing.Literal['ACTIVE', 'CREATING', 'DELETING', 'FAILED', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER', 'UPDATING']]

StateInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.StateInfoTypeDef]

Tags

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

ZookeeperConnectString

  • Type: typing.Optional[str]

ZookeeperConnectStringTls

  • Type: typing.Optional[str]

StorageMode

  • Type: typing.Optional[typing.Literal['LOCAL', 'TIERED']]

CustomerActionStatus

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

ClusterOperationInfoTypeDef

ClientRequestId

  • Type: typing.Optional[str]

ClusterArn

  • Type: typing.Optional[str]

CreationTime

  • Type: typing.Optional[datetime.datetime]

EndTime

  • Type: typing.Optional[datetime.datetime]

ErrorInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ErrorInfoTypeDef]

OperationArn

  • Type: typing.Optional[str]

OperationState

  • Type: typing.Optional[str]

OperationSteps

  • Type: typing.Optional[typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationStepTypeDef]]

OperationType

  • Type: typing.Optional[str]

SourceClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.MutableClusterInfoTypeDef]

TargetClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.MutableClusterInfoTypeDef]

VpcConnectionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectionInfoTypeDef]

ClusterOperationStepInfoTypeDef

StepStatus

  • Type: typing.Optional[str]

ClusterOperationStepTypeDef

StepInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationStepInfoTypeDef]

StepName

  • Type: typing.Optional[str]

ClusterOperationV2ProvisionedTypeDef

OperationSteps

  • Type: typing.Optional[typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationStepTypeDef]]

SourceClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.MutableClusterInfoTypeDef]

TargetClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.MutableClusterInfoTypeDef]

VpcConnectionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectionInfoTypeDef]

ClusterOperationV2ServerlessTypeDef

VpcConnectionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectionInfoServerlessTypeDef]

ClusterOperationV2SummaryTypeDef

ClusterArn

  • Type: typing.Optional[str]

ClusterType

  • Type: typing.Optional[typing.Literal['PROVISIONED', 'SERVERLESS']]

StartTime

  • Type: typing.Optional[datetime.datetime]

EndTime

  • Type: typing.Optional[datetime.datetime]

OperationArn

  • Type: typing.Optional[str]

OperationState

  • Type: typing.Optional[str]

OperationType

  • Type: typing.Optional[str]

ClusterOperationV2TypeDef

ClusterArn

  • Type: typing.Optional[str]

ClusterType

  • Type: typing.Optional[typing.Literal['PROVISIONED', 'SERVERLESS']]

StartTime

  • Type: typing.Optional[datetime.datetime]

EndTime

  • Type: typing.Optional[datetime.datetime]

ErrorInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ErrorInfoTypeDef]

OperationArn

  • Type: typing.Optional[str]

OperationState

  • Type: typing.Optional[str]

OperationType

  • Type: typing.Optional[str]

Provisioned

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationV2ProvisionedTypeDef]

Serverless

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationV2ServerlessTypeDef]

ClusterTypeDef

ActiveOperationArn

  • Type: typing.Optional[str]

ClusterType

  • Type: typing.Optional[typing.Literal['PROVISIONED', 'SERVERLESS']]

ClusterArn

  • Type: typing.Optional[str]

ClusterName

  • Type: typing.Optional[str]

CreationTime

  • Type: typing.Optional[datetime.datetime]

CurrentVersion

  • Type: typing.Optional[str]

State

  • Type: typing.Optional[typing.Literal['ACTIVE', 'CREATING', 'DELETING', 'FAILED', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER', 'UPDATING']]

StateInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.StateInfoTypeDef]

Tags

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

Provisioned

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ProvisionedTypeDef]

Serverless

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ServerlessTypeDef]

CompatibleKafkaVersionTypeDef

SourceVersion

  • Type: typing.Optional[str]

TargetVersions

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

ConfigurationInfoTypeDef

Arn

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

ConfigurationRevisionTypeDef

CreationTime

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

Description

  • Type: typing.Optional[str]

ConfigurationTypeDef

Arn

  • Type:
  • Required: Yes

CreationTime

  • Type:
  • Required: Yes

Description

  • Type:
  • Required: Yes

KafkaVersions

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

LatestRevision

  • Type:
  • Required: Yes

Name

  • Type:
  • Required: Yes

State

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

ConnectivityInfoTypeDef

PublicAccess

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.PublicAccessTypeDef]

VpcConnectivity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectivityTypeDef]

ConsumerGroupReplicationOutputTypeDef

ConsumerGroupsToReplicate

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

ConsumerGroupsToExclude

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

DetectAndCopyNewConsumerGroups

  • Type: typing.Optional[bool]

SynchroniseConsumerGroupOffsets

  • Type: typing.Optional[bool]

ConsumerGroupReplicationTypeDef

ConsumerGroupsToReplicate

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

ConsumerGroupsToExclude

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

DetectAndCopyNewConsumerGroups

  • Type: typing.Optional[bool]

SynchroniseConsumerGroupOffsets

  • Type: typing.Optional[bool]

ConsumerGroupReplicationUpdateTypeDef

ConsumerGroupsToExclude

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

ConsumerGroupsToReplicate

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

DetectAndCopyNewConsumerGroups

  • Type:
  • Required: Yes

SynchroniseConsumerGroupOffsets

  • Type:
  • Required: Yes

ControllerNodeInfoTypeDef

Endpoints

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

CreateClusterRequestRequestTypeDef

BrokerNodeGroupInfo

  • Type:
  • Required: Yes

ClusterName

  • Type:
  • Required: Yes

KafkaVersion

  • Type:
  • Required: Yes

NumberOfBrokerNodes

  • Type:
  • Required: Yes

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClientAuthenticationTypeDef]

ConfigurationInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConfigurationInfoTypeDef]

EncryptionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInfoTypeDef]

EnhancedMonitoring

  • Type: typing.Optional[typing.Literal['DEFAULT', 'PER_BROKER', 'PER_TOPIC_PER_BROKER', 'PER_TOPIC_PER_PARTITION']]

OpenMonitoring

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.OpenMonitoringInfoTypeDef]

LoggingInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.LoggingInfoTypeDef]

Tags

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

StorageMode

  • Type: typing.Optional[typing.Literal['LOCAL', 'TIERED']]

CreateClusterResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterName

  • Type:
  • Required: Yes

State

  • Type: typing.Literal['ACTIVE', 'CREATING', 'DELETING', 'FAILED', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER', 'UPDATING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

CreateClusterV2RequestRequestTypeDef

ClusterName

  • Type:
  • Required: Yes

Tags

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

Provisioned

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ProvisionedRequestTypeDef]

Serverless

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ServerlessRequestTypeDef]

CreateClusterV2ResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterName

  • Type:
  • Required: Yes

State

  • Type: typing.Literal['ACTIVE', 'CREATING', 'DELETING', 'FAILED', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER', 'UPDATING']
  • Required: Yes

ClusterType

  • Type: typing.Literal['PROVISIONED', 'SERVERLESS']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

CreateConfigurationRequestRequestTypeDef

Name

  • Type:
  • Required: Yes

ServerProperties

  • Type: typing.Union[str, bytes, typing.IO[typing.Any]]
  • Required: Yes

Description

  • Type: typing.Optional[str]

KafkaVersions

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

CreateConfigurationResponseTypeDef

Arn

  • Type:
  • Required: Yes

CreationTime

  • Type:
  • Required: Yes

LatestRevision

  • Type:
  • Required: Yes

Name

  • Type:
  • Required: Yes

State

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

ResponseMetadata

  • Type:
  • Required: Yes

CreateReplicatorRequestRequestTypeDef

KafkaClusters

  • Type: typing.Sequence[aws_resource_validator.pydantic_models.kafka_classes.KafkaClusterTypeDef]
  • Required: Yes

ReplicationInfoList

  • Type: typing.Sequence[aws_resource_validator.pydantic_models.kafka_classes.ReplicationInfoTypeDef]
  • Required: Yes

ReplicatorName

  • Type:
  • Required: Yes

ServiceExecutionRoleArn

  • Type:
  • Required: Yes

Description

  • Type: typing.Optional[str]

Tags

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

CreateReplicatorResponseTypeDef

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorName

  • Type:
  • Required: Yes

ReplicatorState

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

ResponseMetadata

  • Type:
  • Required: Yes

CreateVpcConnectionRequestRequestTypeDef

TargetClusterArn

  • Type:
  • Required: Yes

Authentication

  • Type:
  • Required: Yes

VpcId

  • Type:
  • Required: Yes

ClientSubnets

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

SecurityGroups

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

Tags

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

CreateVpcConnectionResponseTypeDef

VpcConnectionArn

  • Type:
  • Required: Yes

State

  • Type: typing.Literal['AVAILABLE', 'CREATING', 'DEACTIVATING', 'DELETING', 'FAILED', 'INACTIVE', 'REJECTED', 'REJECTING']
  • Required: Yes

Authentication

  • Type:
  • Required: Yes

VpcId

  • Type:
  • Required: Yes

ClientSubnets

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

SecurityGroups

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

CreationTime

  • Type:
  • Required: Yes

Tags

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteClusterPolicyRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

DeleteClusterRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type: typing.Optional[str]

DeleteClusterResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

State

  • Type: typing.Literal['ACTIVE', 'CREATING', 'DELETING', 'FAILED', 'HEALING', 'MAINTENANCE', 'REBOOTING_BROKER', 'UPDATING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DeleteConfigurationRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

DeleteConfigurationResponseTypeDef

Arn

  • Type:
  • Required: Yes

State

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteReplicatorRequestRequestTypeDef

ReplicatorArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type: typing.Optional[str]

DeleteReplicatorResponseTypeDef

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorState

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteVpcConnectionRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

DeleteVpcConnectionResponseTypeDef

VpcConnectionArn

  • Type:
  • Required: Yes

State

  • Type: typing.Literal['AVAILABLE', 'CREATING', 'DEACTIVATING', 'DELETING', 'FAILED', 'INACTIVE', 'REJECTED', 'REJECTING']
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterOperationRequestRequestTypeDef

ClusterOperationArn

  • Type:
  • Required: Yes

DescribeClusterOperationResponseTypeDef

ClusterOperationInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterOperationV2RequestRequestTypeDef

ClusterOperationArn

  • Type:
  • Required: Yes

DescribeClusterOperationV2ResponseTypeDef

ClusterOperationInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

DescribeClusterResponseTypeDef

ClusterInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterV2RequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

DescribeClusterV2ResponseTypeDef

ClusterInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeConfigurationRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

DescribeConfigurationResponseTypeDef

Arn

  • Type:
  • Required: Yes

CreationTime

  • Type:
  • Required: Yes

Description

  • Type:
  • Required: Yes

KafkaVersions

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

LatestRevision

  • Type:
  • Required: Yes

Name

  • Type:
  • Required: Yes

State

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

ResponseMetadata

  • Type:
  • Required: Yes

DescribeConfigurationRevisionRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

DescribeConfigurationRevisionResponseTypeDef

Arn

  • Type:
  • Required: Yes

CreationTime

  • Type:
  • Required: Yes

Description

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

ServerProperties

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeReplicatorRequestRequestTypeDef

ReplicatorArn

  • Type:
  • Required: Yes

DescribeReplicatorResponseTypeDef

CreationTime

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

IsReplicatorReference

  • Type:
  • Required: Yes

KafkaClusters

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.KafkaClusterDescriptionTypeDef]
  • Required: Yes

ReplicationInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ReplicationInfoDescriptionTypeDef]
  • Required: Yes

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorDescription

  • Type:
  • Required: Yes

ReplicatorName

  • Type:
  • Required: Yes

ReplicatorResourceArn

  • Type:
  • Required: Yes

ReplicatorState

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

ServiceExecutionRoleArn

  • Type:
  • Required: Yes

StateInfo

  • Type:
  • Required: Yes

Tags

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

ResponseMetadata

  • Type:
  • Required: Yes

DescribeVpcConnectionRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

DescribeVpcConnectionResponseTypeDef

VpcConnectionArn

  • Type:
  • Required: Yes

TargetClusterArn

  • Type:
  • Required: Yes

State

  • Type: typing.Literal['AVAILABLE', 'CREATING', 'DEACTIVATING', 'DELETING', 'FAILED', 'INACTIVE', 'REJECTED', 'REJECTING']
  • Required: Yes

Authentication

  • Type:
  • Required: Yes

VpcId

  • Type:
  • Required: Yes

Subnets

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

SecurityGroups

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

CreationTime

  • Type:
  • Required: Yes

Tags

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

ResponseMetadata

  • Type:
  • Required: Yes

EBSStorageInfoTypeDef

ProvisionedThroughput

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ProvisionedThroughputTypeDef]

VolumeSize

  • Type: typing.Optional[int]

EmptyResponseMetadataTypeDef

ResponseMetadata

  • Type:
  • Required: Yes

EncryptionAtRestTypeDef

DataVolumeKMSKeyId

  • Type:
  • Required: Yes

EncryptionInTransitTypeDef

ClientBroker

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

InCluster

  • Type: typing.Optional[bool]

EncryptionInfoTypeDef

EncryptionAtRest

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionAtRestTypeDef]

EncryptionInTransit

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInTransitTypeDef]

ErrorInfoTypeDef

ErrorCode

  • Type: typing.Optional[str]

ErrorString

  • Type: typing.Optional[str]

FirehoseTypeDef

Enabled

  • Type:
  • Required: Yes

DeliveryStream

  • Type: typing.Optional[str]

GetBootstrapBrokersRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

GetBootstrapBrokersResponseTypeDef

BootstrapBrokerString

  • Type:
  • Required: Yes

BootstrapBrokerStringTls

  • Type:
  • Required: Yes

BootstrapBrokerStringSaslScram

  • Type:
  • Required: Yes

BootstrapBrokerStringSaslIam

  • Type:
  • Required: Yes

BootstrapBrokerStringPublicTls

  • Type:
  • Required: Yes

BootstrapBrokerStringPublicSaslScram

  • Type:
  • Required: Yes

BootstrapBrokerStringPublicSaslIam

  • Type:
  • Required: Yes

BootstrapBrokerStringVpcConnectivityTls

  • Type:
  • Required: Yes

BootstrapBrokerStringVpcConnectivitySaslScram

  • Type:
  • Required: Yes

BootstrapBrokerStringVpcConnectivitySaslIam

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

GetClusterPolicyRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

GetClusterPolicyResponseTypeDef

CurrentVersion

  • Type:
  • Required: Yes

Policy

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

GetCompatibleKafkaVersionsRequestRequestTypeDef

ClusterArn

  • Type: typing.Optional[str]

GetCompatibleKafkaVersionsResponseTypeDef

CompatibleKafkaVersions

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.CompatibleKafkaVersionTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

IamTypeDef

Enabled

  • Type: typing.Optional[bool]

JmxExporterInfoTypeDef

EnabledInBroker

  • Type:
  • Required: Yes

JmxExporterTypeDef

EnabledInBroker

  • Type:
  • Required: Yes

KafkaClusterClientVpcConfigOutputTypeDef

SubnetIds

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

SecurityGroupIds

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

KafkaClusterClientVpcConfigTypeDef

SubnetIds

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

SecurityGroupIds

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

KafkaClusterDescriptionTypeDef

AmazonMskCluster

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.AmazonMskClusterTypeDef]

KafkaClusterAlias

  • Type: typing.Optional[str]

VpcConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.KafkaClusterClientVpcConfigOutputTypeDef]

KafkaClusterSummaryTypeDef

AmazonMskCluster

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.AmazonMskClusterTypeDef]

KafkaClusterAlias

  • Type: typing.Optional[str]

KafkaClusterTypeDef

AmazonMskCluster

  • Type:
  • Required: Yes

VpcConfig

  • Type:
  • Required: Yes

KafkaVersionTypeDef

Version

  • Type: typing.Optional[str]

Status

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

ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

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

ListClientVpcConnectionsRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClientVpcConnectionsResponseTypeDef

ClientVpcConnections

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClientVpcConnectionTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsRequestListClusterOperationsPaginateTypeDef

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

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

ListClusterOperationsRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsResponseTypeDef

ClusterOperationInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationInfoTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsV2RequestListClusterOperationsV2PaginateTypeDef

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

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

ListClusterOperationsV2RequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsV2ResponseTypeDef

ClusterOperationInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClusterOperationV2SummaryTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClustersRequestListClustersPaginateTypeDef

ClusterNameFilter

  • Type: typing.Optional[str]

PaginationConfig

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

ListClustersRequestRequestTypeDef

ClusterNameFilter

  • Type: typing.Optional[str]

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClustersResponseTypeDef

ClusterInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClusterInfoTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClustersV2RequestListClustersV2PaginateTypeDef

ClusterNameFilter

  • Type: typing.Optional[str]

ClusterTypeFilter

  • Type: typing.Optional[str]

PaginationConfig

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

ListClustersV2RequestRequestTypeDef

ClusterNameFilter

  • Type: typing.Optional[str]

ClusterTypeFilter

  • Type: typing.Optional[str]

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClustersV2ResponseTypeDef

ClusterInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ClusterTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef

Arn

  • Type:
  • Required: Yes

PaginationConfig

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

ListConfigurationRevisionsRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListConfigurationRevisionsResponseTypeDef

Revisions

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ConfigurationRevisionTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListConfigurationsRequestListConfigurationsPaginateTypeDef

PaginationConfig

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

ListConfigurationsRequestRequestTypeDef

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListConfigurationsResponseTypeDef

Configurations

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ConfigurationTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef

PaginationConfig

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

ListKafkaVersionsRequestRequestTypeDef

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListKafkaVersionsResponseTypeDef

KafkaVersions

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.KafkaVersionTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListNodesRequestListNodesPaginateTypeDef

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

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

ListNodesRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListNodesResponseTypeDef

NodeInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.NodeInfoTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListReplicatorsRequestListReplicatorsPaginateTypeDef

ReplicatorNameFilter

  • Type: typing.Optional[str]

PaginationConfig

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

ListReplicatorsRequestRequestTypeDef

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ReplicatorNameFilter

  • Type: typing.Optional[str]

ListReplicatorsResponseTypeDef

Replicators

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.ReplicatorSummaryTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListScramSecretsRequestListScramSecretsPaginateTypeDef

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

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

ListScramSecretsRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListScramSecretsResponseTypeDef

SecretArnList

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListTagsForResourceRequestRequestTypeDef

ResourceArn

  • Type:
  • Required: Yes

ListTagsForResourceResponseTypeDef

Tags

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

ResponseMetadata

  • Type:
  • Required: Yes

ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef

PaginationConfig

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

ListVpcConnectionsRequestRequestTypeDef

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListVpcConnectionsResponseTypeDef

VpcConnections

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectionTypeDef]
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

LoggingInfoTypeDef

BrokerLogs

  • Type:
  • Required: Yes

MutableClusterInfoTypeDef

BrokerEBSVolumeInfo

  • Type: typing.Optional[typing.List[aws_resource_validator.pydantic_models.kafka_classes.BrokerEBSVolumeInfoTypeDef]]

ConfigurationInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConfigurationInfoTypeDef]

NumberOfBrokerNodes

  • Type: typing.Optional[int]

EnhancedMonitoring

  • Type: typing.Optional[typing.Literal['DEFAULT', 'PER_BROKER', 'PER_TOPIC_PER_BROKER', 'PER_TOPIC_PER_PARTITION']]

OpenMonitoring

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.OpenMonitoringTypeDef]

KafkaVersion

  • Type: typing.Optional[str]

LoggingInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.LoggingInfoTypeDef]

InstanceType

  • Type: typing.Optional[str]

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClientAuthenticationOutputTypeDef]

EncryptionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInfoTypeDef]

ConnectivityInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConnectivityInfoTypeDef]

StorageMode

  • Type: typing.Optional[typing.Literal['LOCAL', 'TIERED']]

BrokerCountUpdateInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.BrokerCountUpdateInfoTypeDef]

NodeExporterInfoTypeDef

EnabledInBroker

  • Type:
  • Required: Yes

NodeExporterTypeDef

EnabledInBroker

  • Type:
  • Required: Yes

NodeInfoTypeDef

AddedToClusterTime

  • Type: typing.Optional[str]

BrokerNodeInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.BrokerNodeInfoTypeDef]

ControllerNodeInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ControllerNodeInfoTypeDef]

InstanceType

  • Type: typing.Optional[str]

NodeARN

  • Type: typing.Optional[str]

NodeType

  • Type: typing.Optional[typing.Literal['BROKER']]

ZookeeperNodeInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ZookeeperNodeInfoTypeDef]

OpenMonitoringInfoTypeDef

Prometheus

  • Type:
  • Required: Yes

OpenMonitoringTypeDef

Prometheus

  • Type:
  • Required: Yes

PaginatorConfigTypeDef

MaxItems

  • Type: typing.Optional[int]

PageSize

  • Type: typing.Optional[int]

StartingToken

  • Type: typing.Optional[str]

PrometheusInfoTypeDef

JmxExporter

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.JmxExporterInfoTypeDef]

NodeExporter

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.NodeExporterInfoTypeDef]

PrometheusTypeDef

JmxExporter

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.JmxExporterTypeDef]

NodeExporter

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.NodeExporterTypeDef]

ProvisionedRequestTypeDef

BrokerNodeGroupInfo

  • Type:
  • Required: Yes

KafkaVersion

  • Type:
  • Required: Yes

NumberOfBrokerNodes

  • Type:
  • Required: Yes

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClientAuthenticationTypeDef]

ConfigurationInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConfigurationInfoTypeDef]

EncryptionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInfoTypeDef]

EnhancedMonitoring

  • Type: typing.Optional[typing.Literal['DEFAULT', 'PER_BROKER', 'PER_TOPIC_PER_BROKER', 'PER_TOPIC_PER_PARTITION']]

OpenMonitoring

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.OpenMonitoringInfoTypeDef]

LoggingInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.LoggingInfoTypeDef]

StorageMode

  • Type: typing.Optional[typing.Literal['LOCAL', 'TIERED']]

ProvisionedThroughputTypeDef

Enabled

  • Type: typing.Optional[bool]

VolumeThroughput

  • Type: typing.Optional[int]

ProvisionedTypeDef

BrokerNodeGroupInfo

  • Type:
  • Required: Yes

NumberOfBrokerNodes

  • Type:
  • Required: Yes

CurrentBrokerSoftwareInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.BrokerSoftwareInfoTypeDef]

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClientAuthenticationOutputTypeDef]

EncryptionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInfoTypeDef]

EnhancedMonitoring

  • Type: typing.Optional[typing.Literal['DEFAULT', 'PER_BROKER', 'PER_TOPIC_PER_BROKER', 'PER_TOPIC_PER_PARTITION']]

OpenMonitoring

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.OpenMonitoringInfoTypeDef]

LoggingInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.LoggingInfoTypeDef]

ZookeeperConnectString

  • Type: typing.Optional[str]

ZookeeperConnectStringTls

  • Type: typing.Optional[str]

StorageMode

  • Type: typing.Optional[typing.Literal['LOCAL', 'TIERED']]

CustomerActionStatus

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

PublicAccessTypeDef

Type

  • Type: typing.Optional[str]

PutClusterPolicyRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

Policy

  • Type:
  • Required: Yes

CurrentVersion

  • Type: typing.Optional[str]

PutClusterPolicyResponseTypeDef

CurrentVersion

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

RebootBrokerRequestRequestTypeDef

BrokerIds

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

ClusterArn

  • Type:
  • Required: Yes

RebootBrokerResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

RejectClientVpcConnectionRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

VpcConnectionArn

  • Type:
  • Required: Yes

ReplicationInfoDescriptionTypeDef

ConsumerGroupReplication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConsumerGroupReplicationOutputTypeDef]

SourceKafkaClusterAlias

  • Type: typing.Optional[str]

TargetCompressionType

  • Type: typing.Optional[typing.Literal['GZIP', 'LZ4', 'NONE', 'SNAPPY', 'ZSTD']]

TargetKafkaClusterAlias

  • Type: typing.Optional[str]

TopicReplication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.TopicReplicationOutputTypeDef]

ReplicationInfoSummaryTypeDef

SourceKafkaClusterAlias

  • Type: typing.Optional[str]

TargetKafkaClusterAlias

  • Type: typing.Optional[str]

ReplicationInfoTypeDef

ConsumerGroupReplication

  • Type:
  • Required: Yes

SourceKafkaClusterArn

  • Type:
  • Required: Yes

TargetCompressionType

  • Type: typing.Literal['GZIP', 'LZ4', 'NONE', 'SNAPPY', 'ZSTD']
  • Required: Yes

TargetKafkaClusterArn

  • Type:
  • Required: Yes

TopicReplication

  • Type:
  • Required: Yes

ReplicationStartingPositionTypeDef

Type

  • Type: typing.Optional[typing.Literal['EARLIEST', 'LATEST']]

ReplicationStateInfoTypeDef

Code

  • Type: typing.Optional[str]

Message

  • Type: typing.Optional[str]

ReplicatorSummaryTypeDef

CreationTime

  • Type: typing.Optional[datetime.datetime]

CurrentVersion

  • Type: typing.Optional[str]

IsReplicatorReference

  • Type: typing.Optional[bool]

KafkaClustersSummary

  • Type: typing.Optional[typing.List[aws_resource_validator.pydantic_models.kafka_classes.KafkaClusterSummaryTypeDef]]

ReplicationInfoSummaryList

  • Type: typing.Optional[typing.List[aws_resource_validator.pydantic_models.kafka_classes.ReplicationInfoSummaryTypeDef]]

ReplicatorArn

  • Type: typing.Optional[str]

ReplicatorName

  • Type: typing.Optional[str]

ReplicatorResourceArn

  • Type: typing.Optional[str]

ReplicatorState

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

ResponseMetadataTypeDef

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]

S3TypeDef

Enabled

  • Type:
  • Required: Yes

Bucket

  • Type: typing.Optional[str]

Prefix

  • Type: typing.Optional[str]

SaslTypeDef

Scram

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ScramTypeDef]

Iam

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.IamTypeDef]

ScramTypeDef

Enabled

  • Type: typing.Optional[bool]

ServerlessClientAuthenticationTypeDef

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ServerlessSaslTypeDef]

ServerlessRequestTypeDef

VpcConfigs

  • Type: typing.Sequence[aws_resource_validator.pydantic_models.kafka_classes.VpcConfigTypeDef]
  • Required: Yes

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ServerlessClientAuthenticationTypeDef]

ServerlessSaslTypeDef

Iam

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.IamTypeDef]

ServerlessTypeDef

VpcConfigs

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka_classes.VpcConfigOutputTypeDef]
  • Required: Yes

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ServerlessClientAuthenticationTypeDef]

StateInfoTypeDef

Code

  • Type: typing.Optional[str]

Message

  • Type: typing.Optional[str]

StorageInfoTypeDef

EbsStorageInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EBSStorageInfoTypeDef]

TagResourceRequestRequestTypeDef

ResourceArn

  • Type:
  • Required: Yes

Tags

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

TlsExtraOutputTypeDef

CertificateAuthorityArnList

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

Enabled

  • Type: typing.Optional[bool]

TlsOutputTypeDef

CertificateAuthorityArnList

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

Enabled

  • Type: typing.Optional[bool]

TlsTypeDef

CertificateAuthorityArnList

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

Enabled

  • Type: typing.Optional[bool]

TopicReplicationOutputTypeDef

TopicsToReplicate

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

CopyAccessControlListsForTopics

  • Type: typing.Optional[bool]

CopyTopicConfigurations

  • Type: typing.Optional[bool]

DetectAndCopyNewTopics

  • Type: typing.Optional[bool]

StartingPosition

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ReplicationStartingPositionTypeDef]

TopicsToExclude

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

TopicReplicationTypeDef

TopicsToReplicate

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

CopyAccessControlListsForTopics

  • Type: typing.Optional[bool]

CopyTopicConfigurations

  • Type: typing.Optional[bool]

DetectAndCopyNewTopics

  • Type: typing.Optional[bool]

StartingPosition

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ReplicationStartingPositionTypeDef]

TopicsToExclude

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

TopicReplicationUpdateTypeDef

CopyAccessControlListsForTopics

  • Type:
  • Required: Yes

CopyTopicConfigurations

  • Type:
  • Required: Yes

DetectAndCopyNewTopics

  • Type:
  • Required: Yes

TopicsToExclude

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

TopicsToReplicate

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

UnauthenticatedTypeDef

Enabled

  • Type: typing.Optional[bool]

UnprocessedScramSecretTypeDef

ErrorCode

  • Type: typing.Optional[str]

ErrorMessage

  • Type: typing.Optional[str]

SecretArn

  • Type: typing.Optional[str]

UntagResourceRequestRequestTypeDef

ResourceArn

  • Type:
  • Required: Yes

TagKeys

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

UpdateBrokerCountRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetNumberOfBrokerNodes

  • Type:
  • Required: Yes

UpdateBrokerCountResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateBrokerStorageRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetBrokerEBSVolumeInfo

  • Type: typing.Sequence[aws_resource_validator.pydantic_models.kafka_classes.BrokerEBSVolumeInfoTypeDef]
  • Required: Yes

UpdateBrokerStorageResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateBrokerTypeRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetInstanceType

  • Type:
  • Required: Yes

UpdateBrokerTypeResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateClusterConfigurationRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

ConfigurationInfo

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

UpdateClusterConfigurationResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateClusterKafkaVersionRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetKafkaVersion

  • Type:
  • Required: Yes

ConfigurationInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConfigurationInfoTypeDef]

UpdateClusterKafkaVersionResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateConfigurationRequestRequestTypeDef

Arn

  • Type:
  • Required: Yes

ServerProperties

  • Type: typing.Union[str, bytes, typing.IO[typing.Any]]
  • Required: Yes

Description

  • Type: typing.Optional[str]

UpdateConfigurationResponseTypeDef

Arn

  • Type:
  • Required: Yes

LatestRevision

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateConnectivityRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

ConnectivityInfo

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

UpdateConnectivityResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateMonitoringRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

EnhancedMonitoring

  • Type: typing.Optional[typing.Literal['DEFAULT', 'PER_BROKER', 'PER_TOPIC_PER_BROKER', 'PER_TOPIC_PER_PARTITION']]

OpenMonitoring

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.OpenMonitoringInfoTypeDef]

LoggingInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.LoggingInfoTypeDef]

UpdateMonitoringResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateReplicationInfoRequestRequestTypeDef

CurrentVersion

  • Type:
  • Required: Yes

ReplicatorArn

  • Type:
  • Required: Yes

SourceKafkaClusterArn

  • Type:
  • Required: Yes

TargetKafkaClusterArn

  • Type:
  • Required: Yes

ConsumerGroupReplication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ConsumerGroupReplicationUpdateTypeDef]

TopicReplication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.TopicReplicationUpdateTypeDef]

UpdateReplicationInfoResponseTypeDef

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorState

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

ResponseMetadata

  • Type:
  • Required: Yes

UpdateSecurityRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ClientAuthenticationTypeDef]

EncryptionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.EncryptionInfoTypeDef]

UpdateSecurityResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateStorageRequestRequestTypeDef

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

ProvisionedThroughput

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.ProvisionedThroughputTypeDef]

StorageMode

  • Type: typing.Optional[typing.Literal['LOCAL', 'TIERED']]

VolumeSizeGB

  • Type: typing.Optional[int]

UpdateStorageResponseTypeDef

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UserIdentityTypeDef

Type

  • Type: typing.Optional[typing.Literal['AWSACCOUNT', 'AWSSERVICE']]

PrincipalId

  • Type: typing.Optional[str]

VpcConfigOutputTypeDef

SubnetIds

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

SecurityGroupIds

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

VpcConfigTypeDef

SubnetIds

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

SecurityGroupIds

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

VpcConnectionInfoServerlessTypeDef

CreationTime

  • Type: typing.Optional[datetime.datetime]

Owner

  • Type: typing.Optional[str]

UserIdentity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.UserIdentityTypeDef]

VpcConnectionArn

  • Type: typing.Optional[str]

VpcConnectionInfoTypeDef

VpcConnectionArn

  • Type: typing.Optional[str]

Owner

  • Type: typing.Optional[str]

UserIdentity

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.UserIdentityTypeDef]

CreationTime

  • Type: typing.Optional[datetime.datetime]

VpcConnectionTypeDef

VpcConnectionArn

  • Type:
  • Required: Yes

TargetClusterArn

  • Type:
  • Required: Yes

CreationTime

  • Type: typing.Optional[datetime.datetime]

Authentication

  • Type: typing.Optional[str]

VpcId

  • Type: typing.Optional[str]

State

  • Type: typing.Optional[typing.Literal['AVAILABLE', 'CREATING', 'DEACTIVATING', 'DELETING', 'FAILED', 'INACTIVE', 'REJECTED', 'REJECTING']]

VpcConnectivityClientAuthenticationTypeDef

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectivitySaslTypeDef]

Tls

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectivityTlsTypeDef]

VpcConnectivityIamTypeDef

Enabled

  • Type: typing.Optional[bool]

VpcConnectivitySaslTypeDef

Scram

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectivityScramTypeDef]

Iam

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectivityIamTypeDef]

VpcConnectivityScramTypeDef

Enabled

  • Type: typing.Optional[bool]

VpcConnectivityTlsTypeDef

Enabled

  • Type: typing.Optional[bool]

VpcConnectivityTypeDef

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka_classes.VpcConnectivityClientAuthenticationTypeDef]

ZookeeperNodeInfoTypeDef

AttachedENIId

  • Type: typing.Optional[str]

ClientVpcIpAddress

  • Type: typing.Optional[str]

Endpoints

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

ZookeeperId

  • Type: typing.Optional[float]

ZookeeperVersion

  • Type: typing.Optional[str]