Skip to content

Kafka Classes

AmazonMskCluster

MskClusterArn

  • Type:
  • Required: Yes

BaseValidatorModel

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

BatchAssociateScramSecretRequest

ClusterArn

  • Type:
  • Required: Yes

SecretArnList

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

BatchAssociateScramSecretResponse

ClusterArn

  • Type:
  • Required: Yes

UnprocessedScramSecrets

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

ResponseMetadata

  • Type:
  • Required: Yes

BatchDisassociateScramSecretRequest

ClusterArn

  • Type:
  • Required: Yes

SecretArnList

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

BatchDisassociateScramSecretResponse

ClusterArn

  • Type:
  • Required: Yes

UnprocessedScramSecrets

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

ResponseMetadata

  • Type:
  • Required: Yes

BrokerCountUpdateInfo

CreatedBrokerIds

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

DeletedBrokerIds

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

BrokerEBSVolumeInfo

KafkaBrokerNodeId

  • Type:
  • Required: Yes

ProvisionedThroughput

  • Type:

VolumeSizeGB

  • Type: typing.Optional[int]

BrokerLogs

CloudWatchLogs

  • Type:

Firehose

  • Type:

S3

  • Type:

BrokerNodeGroupInfo

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:

ConnectivityInfo

  • Type:

ZoneIds

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

BrokerNodeGroupInfoOutput

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:

ConnectivityInfo

  • Type:

ZoneIds

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

BrokerNodeInfo

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.kafka_classes.BrokerSoftwareInfo]

Endpoints

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

BrokerSoftwareInfo

ConfigurationArn

  • Type: typing.Optional[str]

ConfigurationRevision

  • Type: typing.Optional[int]

KafkaVersion

  • Type: typing.Optional[str]

ClientAuthentication

Sasl

  • Type:

Tls

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.Tls, aws_resource_validator.pydantic_models.kafka.kafka_classes.TlsOutput, NoneType]

Unauthenticated

  • Type:

ClientAuthenticationOutput

Sasl

  • Type:

Tls

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.TlsOutput]

Unauthenticated

  • Type:

ClientVpcConnection

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]

CloudWatchLogs

Enabled

  • Type:
  • Required: Yes

LogGroup

  • Type: typing.Optional[str]

Cluster

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:

Tags

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

Provisioned

  • Type:

Serverless

  • Type:

ClusterInfo

ActiveOperationArn

  • Type: typing.Optional[str]

BrokerNodeGroupInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.BrokerNodeGroupInfoOutput]

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthenticationOutput]

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.kafka_classes.BrokerSoftwareInfo]

CurrentVersion

  • Type: typing.Optional[str]

EncryptionInfo

  • Type:

EnhancedMonitoring

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

OpenMonitoring

  • Type:

LoggingInfo

  • Type:

NumberOfBrokerNodes

  • Type: typing.Optional[int]

State

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

StateInfo

  • Type:

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']]

ClusterOperationInfo

ClientRequestId

  • Type: typing.Optional[str]

ClusterArn

  • Type: typing.Optional[str]

CreationTime

  • Type: typing.Optional[datetime.datetime]

EndTime

  • Type: typing.Optional[datetime.datetime]

ErrorInfo

  • Type:

OperationArn

  • Type: typing.Optional[str]

OperationState

  • Type: typing.Optional[str]

OperationSteps

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

OperationType

  • Type: typing.Optional[str]

SourceClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.MutableClusterInfo]

TargetClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.MutableClusterInfo]

VpcConnectionInfo

  • Type:

ClusterOperationStep

StepInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClusterOperationStepInfo]

StepName

  • Type: typing.Optional[str]

ClusterOperationStepInfo

StepStatus

  • Type: typing.Optional[str]

ClusterOperationV2

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:

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.kafka_classes.ClusterOperationV2Provisioned]

Serverless

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClusterOperationV2Serverless]

ClusterOperationV2Provisioned

OperationSteps

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

SourceClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.MutableClusterInfo]

TargetClusterInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.MutableClusterInfo]

VpcConnectionInfo

  • Type:

ClusterOperationV2Serverless

VpcConnectionInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConnectionInfoServerless]

ClusterOperationV2Summary

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]

CompatibleKafkaVersion

SourceVersion

  • Type: typing.Optional[str]

TargetVersions

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

Configuration

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

ConfigurationInfo

Arn

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

ConfigurationRevision

CreationTime

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

Description

  • Type: typing.Optional[str]

ConnectivityInfo

PublicAccess

  • Type:

VpcConnectivity

  • Type:

ConsumerGroupReplication

ConsumerGroupsToReplicate

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

ConsumerGroupsToExclude

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

DetectAndCopyNewConsumerGroups

  • Type: typing.Optional[bool]

SynchroniseConsumerGroupOffsets

  • Type: typing.Optional[bool]

ConsumerGroupReplicationOutput

ConsumerGroupsToReplicate

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

ConsumerGroupsToExclude

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

DetectAndCopyNewConsumerGroups

  • Type: typing.Optional[bool]

SynchroniseConsumerGroupOffsets

  • Type: typing.Optional[bool]

ConsumerGroupReplicationUpdate

ConsumerGroupsToExclude

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

ConsumerGroupsToReplicate

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

DetectAndCopyNewConsumerGroups

  • Type:
  • Required: Yes

SynchroniseConsumerGroupOffsets

  • Type:
  • Required: Yes

ControllerNodeInfo

Endpoints

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

CreateClusterRequest

BrokerNodeGroupInfo

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.BrokerNodeGroupInfo, aws_resource_validator.pydantic_models.kafka.kafka_classes.BrokerNodeGroupInfoOutput]
  • Required: Yes

ClusterName

  • Type:
  • Required: Yes

KafkaVersion

  • Type:
  • Required: Yes

NumberOfBrokerNodes

  • Type:
  • Required: Yes

ClientAuthentication

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthentication, aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthenticationOutput, NoneType]

ConfigurationInfo

  • Type:

EncryptionInfo

  • Type:

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.kafka_classes.OpenMonitoringInfo]

LoggingInfo

  • Type:

Tags

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

StorageMode

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

CreateClusterResponse

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

CreateClusterV2Request

ClusterName

  • Type:
  • Required: Yes

Tags

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

Provisioned

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ProvisionedRequest]

Serverless

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ServerlessRequest]

CreateClusterV2Response

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

CreateConfigurationRequest

Name

  • Type:
  • Required: Yes

ServerProperties

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

Description

  • Type: typing.Optional[str]

KafkaVersions

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

CreateConfigurationResponse

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

CreateReplicatorRequest

KafkaClusters

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

ReplicationInfoList

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

ReplicatorName

  • Type:
  • Required: Yes

ServiceExecutionRoleArn

  • Type:
  • Required: Yes

Description

  • Type: typing.Optional[str]

Tags

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

CreateReplicatorResponse

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorName

  • Type:
  • Required: Yes

ReplicatorState

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

ResponseMetadata

  • Type:
  • Required: Yes

CreateVpcConnectionRequest

TargetClusterArn

  • Type:
  • Required: Yes

Authentication

  • Type:
  • Required: Yes

VpcId

  • Type:
  • Required: Yes

ClientSubnets

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

SecurityGroups

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

Tags

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

CreateVpcConnectionResponse

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

DeleteClusterPolicyRequest

ClusterArn

  • Type:
  • Required: Yes

DeleteClusterRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type: typing.Optional[str]

DeleteClusterResponse

ClusterArn

  • Type:
  • Required: Yes

State

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteConfigurationRequest

Arn

  • Type:
  • Required: Yes

DeleteConfigurationResponse

Arn

  • Type:
  • Required: Yes

State

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteReplicatorRequest

ReplicatorArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type: typing.Optional[str]

DeleteReplicatorResponse

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorState

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

ResponseMetadata

  • Type:
  • Required: Yes

DeleteVpcConnectionRequest

Arn

  • Type:
  • Required: Yes

DeleteVpcConnectionResponse

VpcConnectionArn

  • Type:
  • Required: Yes

State

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

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterOperationRequest

ClusterOperationArn

  • Type:
  • Required: Yes

DescribeClusterOperationResponse

ClusterOperationInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterOperationV2Request

ClusterOperationArn

  • Type:
  • Required: Yes

DescribeClusterOperationV2Response

ClusterOperationInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterRequest

ClusterArn

  • Type:
  • Required: Yes

DescribeClusterResponse

ClusterInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeClusterV2Request

ClusterArn

  • Type:
  • Required: Yes

DescribeClusterV2Response

ClusterInfo

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeConfigurationRequest

Arn

  • Type:
  • Required: Yes

DescribeConfigurationResponse

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

DescribeConfigurationRevisionRequest

Arn

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

DescribeConfigurationRevisionResponse

Arn

  • Type:
  • Required: Yes

CreationTime

  • Type:
  • Required: Yes

Description

  • Type:
  • Required: Yes

Revision

  • Type:
  • Required: Yes

ServerProperties

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

DescribeReplicatorRequest

ReplicatorArn

  • Type:
  • Required: Yes

DescribeReplicatorResponse

CreationTime

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

IsReplicatorReference

  • Type:
  • Required: Yes

KafkaClusters

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

ReplicationInfoList

  • Type: typing.List[aws_resource_validator.pydantic_models.kafka.kafka_classes.ReplicationInfoDescription]
  • 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

DescribeVpcConnectionRequest

Arn

  • Type:
  • Required: Yes

DescribeVpcConnectionResponse

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

EBSStorageInfo

ProvisionedThroughput

  • Type:

VolumeSize

  • Type: typing.Optional[int]

EmptyResponseMetadata

ResponseMetadata

  • Type:
  • Required: Yes

EncryptionAtRest

DataVolumeKMSKeyId

  • Type:
  • Required: Yes

EncryptionInTransit

ClientBroker

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

InCluster

  • Type: typing.Optional[bool]

EncryptionInfo

EncryptionAtRest

  • Type:

EncryptionInTransit

  • Type:

ErrorInfo

ErrorCode

  • Type: typing.Optional[str]

ErrorString

  • Type: typing.Optional[str]

Firehose

Enabled

  • Type:
  • Required: Yes

DeliveryStream

  • Type: typing.Optional[str]

GetBootstrapBrokersRequest

ClusterArn

  • Type:
  • Required: Yes

GetBootstrapBrokersResponse

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

GetClusterPolicyRequest

ClusterArn

  • Type:
  • Required: Yes

GetClusterPolicyResponse

CurrentVersion

  • Type:
  • Required: Yes

Policy

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

GetCompatibleKafkaVersionsRequest

ClusterArn

  • Type: typing.Optional[str]

GetCompatibleKafkaVersionsResponse

CompatibleKafkaVersions

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

ResponseMetadata

  • Type:
  • Required: Yes

Iam

Enabled

  • Type: typing.Optional[bool]

JmxExporter

EnabledInBroker

  • Type:
  • Required: Yes

JmxExporterInfo

EnabledInBroker

  • Type:
  • Required: Yes

KafkaCluster

AmazonMskCluster

  • Type:
  • Required: Yes

VpcConfig

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.KafkaClusterClientVpcConfig, aws_resource_validator.pydantic_models.kafka.kafka_classes.KafkaClusterClientVpcConfigOutput]
  • Required: Yes

KafkaClusterClientVpcConfig

SubnetIds

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

SecurityGroupIds

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

KafkaClusterClientVpcConfigOutput

SubnetIds

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

SecurityGroupIds

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

KafkaClusterDescription

AmazonMskCluster

  • Type:

KafkaClusterAlias

  • Type: typing.Optional[str]

VpcConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.KafkaClusterClientVpcConfigOutput]

KafkaClusterSummary

AmazonMskCluster

  • Type:

KafkaClusterAlias

  • Type: typing.Optional[str]

KafkaVersion

Version

  • Type: typing.Optional[str]

Status

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

ListClientVpcConnectionsRequest

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClientVpcConnectionsRequestPaginate

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListClientVpcConnectionsResponse

ClientVpcConnections

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsRequest

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsRequestPaginate

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListClusterOperationsResponse

ClusterOperationInfoList

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsV2Request

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClusterOperationsV2RequestPaginate

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListClusterOperationsV2Response

ClusterOperationInfoList

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClustersRequest

ClusterNameFilter

  • Type: typing.Optional[str]

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClustersRequestPaginate

ClusterNameFilter

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListClustersResponse

ClusterInfoList

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListClustersV2Request

ClusterNameFilter

  • Type: typing.Optional[str]

ClusterTypeFilter

  • Type: typing.Optional[str]

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListClustersV2RequestPaginate

ClusterNameFilter

  • Type: typing.Optional[str]

ClusterTypeFilter

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListClustersV2Response

ClusterInfoList

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListConfigurationRevisionsRequest

Arn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListConfigurationRevisionsRequestPaginate

Arn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListConfigurationRevisionsResponse

Revisions

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListConfigurationsRequest

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListConfigurationsRequestPaginate

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListConfigurationsResponse

Configurations

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListKafkaVersionsRequest

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListKafkaVersionsRequestPaginate

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListKafkaVersionsResponse

KafkaVersions

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListNodesRequest

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListNodesRequestPaginate

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListNodesResponse

NodeInfoList

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListReplicatorsRequest

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ReplicatorNameFilter

  • Type: typing.Optional[str]

ListReplicatorsRequestPaginate

ReplicatorNameFilter

  • Type: typing.Optional[str]

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListReplicatorsResponse

Replicators

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

ListScramSecretsRequest

ClusterArn

  • Type:
  • Required: Yes

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListScramSecretsRequestPaginate

ClusterArn

  • Type:
  • Required: Yes

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListScramSecretsResponse

SecretArnList

  • Type: typing.List[str]
  • 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

ListVpcConnectionsRequest

MaxResults

  • Type: typing.Optional[int]

NextToken

  • Type: typing.Optional[str]

ListVpcConnectionsRequestPaginate

PaginationConfig

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.PaginatorConfig]

ListVpcConnectionsResponse

VpcConnections

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

ResponseMetadata

  • Type:
  • Required: Yes

NextToken

  • Type: typing.Optional[str]

LoggingInfo

BrokerLogs

  • Type:
  • Required: Yes

MutableClusterInfo

BrokerEBSVolumeInfo

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

ConfigurationInfo

  • Type:

NumberOfBrokerNodes

  • Type: typing.Optional[int]

EnhancedMonitoring

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

OpenMonitoring

  • Type:

KafkaVersion

  • Type: typing.Optional[str]

LoggingInfo

  • Type:

InstanceType

  • Type: typing.Optional[str]

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthenticationOutput]

EncryptionInfo

  • Type:

ConnectivityInfo

  • Type:

StorageMode

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

BrokerCountUpdateInfo

  • Type:

NodeExporter

EnabledInBroker

  • Type:
  • Required: Yes

NodeExporterInfo

EnabledInBroker

  • Type:
  • Required: Yes

NodeInfo

AddedToClusterTime

  • Type: typing.Optional[str]

BrokerNodeInfo

  • Type:

ControllerNodeInfo

  • Type:

InstanceType

  • Type: typing.Optional[str]

NodeARN

  • Type: typing.Optional[str]

NodeType

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

ZookeeperNodeInfo

  • Type:

OpenMonitoring

Prometheus

  • Type:
  • Required: Yes

OpenMonitoringInfo

Prometheus

  • Type:
  • Required: Yes

PaginatorConfig

MaxItems

  • Type: typing.Optional[int]

PageSize

  • Type: typing.Optional[int]

StartingToken

  • Type: typing.Optional[str]

Prometheus

JmxExporter

  • Type:

NodeExporter

  • Type:

PrometheusInfo

JmxExporter

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.JmxExporterInfo]

NodeExporter

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.NodeExporterInfo]

Provisioned

BrokerNodeGroupInfo

  • Type:
  • Required: Yes

NumberOfBrokerNodes

  • Type:
  • Required: Yes

CurrentBrokerSoftwareInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.BrokerSoftwareInfo]

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthenticationOutput]

EncryptionInfo

  • Type:

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.kafka_classes.OpenMonitoringInfo]

LoggingInfo

  • Type:

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']]

ProvisionedRequest

BrokerNodeGroupInfo

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.BrokerNodeGroupInfo, aws_resource_validator.pydantic_models.kafka.kafka_classes.BrokerNodeGroupInfoOutput]
  • Required: Yes

KafkaVersion

  • Type:
  • Required: Yes

NumberOfBrokerNodes

  • Type:
  • Required: Yes

ClientAuthentication

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthentication, aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthenticationOutput, NoneType]

ConfigurationInfo

  • Type:

EncryptionInfo

  • Type:

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.kafka_classes.OpenMonitoringInfo]

LoggingInfo

  • Type:

StorageMode

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

ProvisionedThroughput

Enabled

  • Type: typing.Optional[bool]

VolumeThroughput

  • Type: typing.Optional[int]

PublicAccess

Type

  • Type: typing.Optional[str]

PutClusterPolicyRequest

ClusterArn

  • Type:
  • Required: Yes

Policy

  • Type:
  • Required: Yes

CurrentVersion

  • Type: typing.Optional[str]

PutClusterPolicyResponse

CurrentVersion

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

RebootBrokerRequest

BrokerIds

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

ClusterArn

  • Type:
  • Required: Yes

RebootBrokerResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

RejectClientVpcConnectionRequest

ClusterArn

  • Type:
  • Required: Yes

VpcConnectionArn

  • Type:
  • Required: Yes

ReplicationInfo

ConsumerGroupReplication

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.ConsumerGroupReplication, aws_resource_validator.pydantic_models.kafka.kafka_classes.ConsumerGroupReplicationOutput]
  • Required: Yes

SourceKafkaClusterArn

  • Type:
  • Required: Yes

TargetCompressionType

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

TargetKafkaClusterArn

  • Type:
  • Required: Yes

TopicReplication

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.TopicReplication, aws_resource_validator.pydantic_models.kafka.kafka_classes.TopicReplicationOutput]
  • Required: Yes

ReplicationInfoDescription

ConsumerGroupReplication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ConsumerGroupReplicationOutput]

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.kafka_classes.TopicReplicationOutput]

ReplicationInfoSummary

SourceKafkaClusterAlias

  • Type: typing.Optional[str]

TargetKafkaClusterAlias

  • Type: typing.Optional[str]

ReplicationStartingPosition

Type

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

ReplicationStateInfo

Code

  • Type: typing.Optional[str]

Message

  • Type: typing.Optional[str]

ReplicationTopicNameConfiguration

Type

  • Type: typing.Optional[typing.Literal['IDENTICAL', 'PREFIXED_WITH_SOURCE_CLUSTER_ALIAS']]

ReplicatorSummary

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.kafka_classes.KafkaClusterSummary]]

ReplicationInfoSummaryList

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

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']]

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]

S3

Enabled

  • Type:
  • Required: Yes

Bucket

  • Type: typing.Optional[str]

Prefix

  • Type: typing.Optional[str]

Sasl

Scram

  • Type:

Iam

  • Type:

Scram

Enabled

  • Type: typing.Optional[bool]

Serverless

VpcConfigs

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

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ServerlessClientAuthentication]

ServerlessClientAuthentication

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ServerlessSasl]

ServerlessRequest

VpcConfigs

  • Type: typing.List[typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConfig, aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConfigOutput]]
  • Required: Yes

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ServerlessClientAuthentication]

ServerlessSasl

Iam

  • Type:

StateInfo

Code

  • Type: typing.Optional[str]

Message

  • Type: typing.Optional[str]

StorageInfo

EbsStorageInfo

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.EBSStorageInfo]

TagResourceRequest

ResourceArn

  • Type:
  • Required: Yes

Tags

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

Tls

CertificateAuthorityArnList

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

Enabled

  • Type: typing.Optional[bool]

TlsOutput

CertificateAuthorityArnList

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

Enabled

  • Type: typing.Optional[bool]

TopicReplication

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.kafka_classes.ReplicationStartingPosition]

TopicNameConfiguration

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ReplicationTopicNameConfiguration]

TopicsToExclude

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

TopicReplicationOutput

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.kafka_classes.ReplicationStartingPosition]

TopicNameConfiguration

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.ReplicationTopicNameConfiguration]

TopicsToExclude

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

TopicReplicationUpdate

CopyAccessControlListsForTopics

  • Type:
  • Required: Yes

CopyTopicConfigurations

  • Type:
  • Required: Yes

DetectAndCopyNewTopics

  • Type:
  • Required: Yes

TopicsToExclude

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

TopicsToReplicate

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

Unauthenticated

Enabled

  • Type: typing.Optional[bool]

UnprocessedScramSecret

ErrorCode

  • Type: typing.Optional[str]

ErrorMessage

  • Type: typing.Optional[str]

SecretArn

  • Type: typing.Optional[str]

UntagResourceRequest

ResourceArn

  • Type:
  • Required: Yes

TagKeys

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

UpdateBrokerCountRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetNumberOfBrokerNodes

  • Type:
  • Required: Yes

UpdateBrokerCountResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateBrokerStorageRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetBrokerEBSVolumeInfo

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

UpdateBrokerStorageResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateBrokerTypeRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetInstanceType

  • Type:
  • Required: Yes

UpdateBrokerTypeResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateClusterConfigurationRequest

ClusterArn

  • Type:
  • Required: Yes

ConfigurationInfo

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

UpdateClusterConfigurationResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateClusterKafkaVersionRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

TargetKafkaVersion

  • Type:
  • Required: Yes

ConfigurationInfo

  • Type:

UpdateClusterKafkaVersionResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateConfigurationRequest

Arn

  • Type:
  • Required: Yes

ServerProperties

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

Description

  • Type: typing.Optional[str]

UpdateConfigurationResponse

Arn

  • Type:
  • Required: Yes

LatestRevision

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateConnectivityRequest

ClusterArn

  • Type:
  • Required: Yes

ConnectivityInfo

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

UpdateConnectivityResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateMonitoringRequest

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.kafka_classes.OpenMonitoringInfo]

LoggingInfo

  • Type:

UpdateMonitoringResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateReplicationInfoRequest

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.kafka_classes.ConsumerGroupReplicationUpdate]

TopicReplication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.TopicReplicationUpdate]

UpdateReplicationInfoResponse

ReplicatorArn

  • Type:
  • Required: Yes

ReplicatorState

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

ResponseMetadata

  • Type:
  • Required: Yes

UpdateSecurityRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

ClientAuthentication

  • Type: typing.Union[aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthentication, aws_resource_validator.pydantic_models.kafka.kafka_classes.ClientAuthenticationOutput, NoneType]

EncryptionInfo

  • Type:

UpdateSecurityResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UpdateStorageRequest

ClusterArn

  • Type:
  • Required: Yes

CurrentVersion

  • Type:
  • Required: Yes

ProvisionedThroughput

  • Type:

StorageMode

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

VolumeSizeGB

  • Type: typing.Optional[int]

UpdateStorageResponse

ClusterArn

  • Type:
  • Required: Yes

ClusterOperationArn

  • Type:
  • Required: Yes

ResponseMetadata

  • Type:
  • Required: Yes

UserIdentity

Type

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

PrincipalId

  • Type: typing.Optional[str]

VpcConfig

SubnetIds

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

SecurityGroupIds

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

VpcConfigOutput

SubnetIds

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

SecurityGroupIds

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

VpcConnection

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']]

VpcConnectionInfo

VpcConnectionArn

  • Type: typing.Optional[str]

Owner

  • Type: typing.Optional[str]

UserIdentity

  • Type:

CreationTime

  • Type: typing.Optional[datetime.datetime]

VpcConnectionInfoServerless

CreationTime

  • Type: typing.Optional[datetime.datetime]

Owner

  • Type: typing.Optional[str]

UserIdentity

  • Type:

VpcConnectionArn

  • Type: typing.Optional[str]

VpcConnectivity

ClientAuthentication

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConnectivityClientAuthentication]

VpcConnectivityClientAuthentication

Sasl

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConnectivitySasl]

Tls

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConnectivityTls]

VpcConnectivityIam

Enabled

  • Type: typing.Optional[bool]

VpcConnectivitySasl

Scram

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConnectivityScram]

Iam

  • Type: typing.Optional[aws_resource_validator.pydantic_models.kafka.kafka_classes.VpcConnectivityIam]

VpcConnectivityScram

Enabled

  • Type: typing.Optional[bool]

VpcConnectivityTls

Enabled

  • Type: typing.Optional[bool]

ZookeeperNodeInfo

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]