Skip to content

Type definitions#

Index > Kafka > Type definitions

Auto-generated documentation for Kafka type annotations stubs module mypy-boto3-kafka.

BlobTypeDef#

# BlobTypeDef definition

BlobTypeDef = Union[
    str,
    bytes,
    IO[Any],
    StreamingBody,
]

ConsumerGroupReplicationUnionTypeDef#

# ConsumerGroupReplicationUnionTypeDef definition

ConsumerGroupReplicationUnionTypeDef = Union[
    ConsumerGroupReplicationTypeDef,  # (1)
    ConsumerGroupReplicationOutputTypeDef,  # (2)
]
  1. See ConsumerGroupReplicationTypeDef
  2. See ConsumerGroupReplicationOutputTypeDef

KafkaClusterClientVpcConfigUnionTypeDef#

# KafkaClusterClientVpcConfigUnionTypeDef definition

KafkaClusterClientVpcConfigUnionTypeDef = Union[
    KafkaClusterClientVpcConfigTypeDef,  # (1)
    KafkaClusterClientVpcConfigOutputTypeDef,  # (2)
]
  1. See KafkaClusterClientVpcConfigTypeDef
  2. See KafkaClusterClientVpcConfigOutputTypeDef

TlsUnionTypeDef#

# TlsUnionTypeDef definition

TlsUnionTypeDef = Union[
    TlsTypeDef,  # (1)
    TlsOutputTypeDef,  # (2)
]
  1. See TlsTypeDef
  2. See TlsOutputTypeDef

VpcConfigUnionTypeDef#

# VpcConfigUnionTypeDef definition

VpcConfigUnionTypeDef = Union[
    VpcConfigTypeDef,  # (1)
    VpcConfigOutputTypeDef,  # (2)
]
  1. See VpcConfigTypeDef
  2. See VpcConfigOutputTypeDef

TopicReplicationUnionTypeDef#

# TopicReplicationUnionTypeDef definition

TopicReplicationUnionTypeDef = Union[
    TopicReplicationTypeDef,  # (1)
    TopicReplicationOutputTypeDef,  # (2)
]
  1. See TopicReplicationTypeDef
  2. See TopicReplicationOutputTypeDef

ClientAuthenticationUnionTypeDef#

# ClientAuthenticationUnionTypeDef definition

ClientAuthenticationUnionTypeDef = Union[
    ClientAuthenticationTypeDef,  # (1)
    ClientAuthenticationOutputTypeDef,  # (2)
]
  1. See ClientAuthenticationTypeDef
  2. See ClientAuthenticationOutputTypeDef

BrokerNodeGroupInfoUnionTypeDef#

# BrokerNodeGroupInfoUnionTypeDef definition

BrokerNodeGroupInfoUnionTypeDef = Union[
    BrokerNodeGroupInfoTypeDef,  # (1)
    BrokerNodeGroupInfoOutputTypeDef,  # (2)
]
  1. See BrokerNodeGroupInfoTypeDef
  2. See BrokerNodeGroupInfoOutputTypeDef

AmazonMskClusterTypeDef#

# AmazonMskClusterTypeDef definition

class AmazonMskClusterTypeDef(TypedDict):
    MskClusterArn: str,

BatchAssociateScramSecretRequestRequestTypeDef#

# BatchAssociateScramSecretRequestRequestTypeDef definition

class BatchAssociateScramSecretRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    SecretArnList: Sequence[str],

ResponseMetadataTypeDef#

# ResponseMetadataTypeDef definition

class ResponseMetadataTypeDef(TypedDict):
    RequestId: str,
    HTTPStatusCode: int,
    HTTPHeaders: dict[str, str],
    RetryAttempts: int,
    HostId: NotRequired[str],

UnprocessedScramSecretTypeDef#

# UnprocessedScramSecretTypeDef definition

class UnprocessedScramSecretTypeDef(TypedDict):
    ErrorCode: NotRequired[str],
    ErrorMessage: NotRequired[str],
    SecretArn: NotRequired[str],

BatchDisassociateScramSecretRequestRequestTypeDef#

# BatchDisassociateScramSecretRequestRequestTypeDef definition

class BatchDisassociateScramSecretRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    SecretArnList: Sequence[str],

BrokerCountUpdateInfoTypeDef#

# BrokerCountUpdateInfoTypeDef definition

class BrokerCountUpdateInfoTypeDef(TypedDict):
    CreatedBrokerIds: NotRequired[list[float]],
    DeletedBrokerIds: NotRequired[list[float]],

ProvisionedThroughputTypeDef#

# ProvisionedThroughputTypeDef definition

class ProvisionedThroughputTypeDef(TypedDict):
    Enabled: NotRequired[bool],
    VolumeThroughput: NotRequired[int],

CloudWatchLogsTypeDef#

# CloudWatchLogsTypeDef definition

class CloudWatchLogsTypeDef(TypedDict):
    Enabled: bool,
    LogGroup: NotRequired[str],

FirehoseTypeDef#

# FirehoseTypeDef definition

class FirehoseTypeDef(TypedDict):
    Enabled: bool,
    DeliveryStream: NotRequired[str],

S3TypeDef#

# S3TypeDef definition

class S3TypeDef(TypedDict):
    Enabled: bool,
    Bucket: NotRequired[str],
    Prefix: NotRequired[str],

BrokerSoftwareInfoTypeDef#

# BrokerSoftwareInfoTypeDef definition

class BrokerSoftwareInfoTypeDef(TypedDict):
    ConfigurationArn: NotRequired[str],
    ConfigurationRevision: NotRequired[int],
    KafkaVersion: NotRequired[str],

TlsOutputTypeDef#

# TlsOutputTypeDef definition

class TlsOutputTypeDef(TypedDict):
    CertificateAuthorityArnList: NotRequired[list[str]],
    Enabled: NotRequired[bool],

UnauthenticatedTypeDef#

# UnauthenticatedTypeDef definition

class UnauthenticatedTypeDef(TypedDict):
    Enabled: NotRequired[bool],

ClientVpcConnectionTypeDef#

# ClientVpcConnectionTypeDef definition

class ClientVpcConnectionTypeDef(TypedDict):
    VpcConnectionArn: str,
    Authentication: NotRequired[str],
    CreationTime: NotRequired[datetime],
    State: NotRequired[VpcConnectionStateType],  # (1)
    Owner: NotRequired[str],
  1. See VpcConnectionStateType

StateInfoTypeDef#

# StateInfoTypeDef definition

class StateInfoTypeDef(TypedDict):
    Code: NotRequired[str],
    Message: NotRequired[str],

ErrorInfoTypeDef#

# ErrorInfoTypeDef definition

class ErrorInfoTypeDef(TypedDict):
    ErrorCode: NotRequired[str],
    ErrorString: NotRequired[str],

ClusterOperationStepInfoTypeDef#

# ClusterOperationStepInfoTypeDef definition

class ClusterOperationStepInfoTypeDef(TypedDict):
    StepStatus: NotRequired[str],

ClusterOperationV2SummaryTypeDef#

# ClusterOperationV2SummaryTypeDef definition

class ClusterOperationV2SummaryTypeDef(TypedDict):
    ClusterArn: NotRequired[str],
    ClusterType: NotRequired[ClusterTypeType],  # (1)
    StartTime: NotRequired[datetime],
    EndTime: NotRequired[datetime],
    OperationArn: NotRequired[str],
    OperationState: NotRequired[str],
    OperationType: NotRequired[str],
  1. See ClusterTypeType

CompatibleKafkaVersionTypeDef#

# CompatibleKafkaVersionTypeDef definition

class CompatibleKafkaVersionTypeDef(TypedDict):
    SourceVersion: NotRequired[str],
    TargetVersions: NotRequired[list[str]],

ConfigurationInfoTypeDef#

# ConfigurationInfoTypeDef definition

class ConfigurationInfoTypeDef(TypedDict):
    Arn: str,
    Revision: int,

ConfigurationRevisionTypeDef#

# ConfigurationRevisionTypeDef definition

class ConfigurationRevisionTypeDef(TypedDict):
    CreationTime: datetime,
    Revision: int,
    Description: NotRequired[str],

PublicAccessTypeDef#

# PublicAccessTypeDef definition

class PublicAccessTypeDef(TypedDict):
    Type: NotRequired[str],

ConsumerGroupReplicationOutputTypeDef#

# ConsumerGroupReplicationOutputTypeDef definition

class ConsumerGroupReplicationOutputTypeDef(TypedDict):
    ConsumerGroupsToReplicate: list[str],
    ConsumerGroupsToExclude: NotRequired[list[str]],
    DetectAndCopyNewConsumerGroups: NotRequired[bool],
    SynchroniseConsumerGroupOffsets: NotRequired[bool],

ConsumerGroupReplicationTypeDef#

# ConsumerGroupReplicationTypeDef definition

class ConsumerGroupReplicationTypeDef(TypedDict):
    ConsumerGroupsToReplicate: Sequence[str],
    ConsumerGroupsToExclude: NotRequired[Sequence[str]],
    DetectAndCopyNewConsumerGroups: NotRequired[bool],
    SynchroniseConsumerGroupOffsets: NotRequired[bool],

ConsumerGroupReplicationUpdateTypeDef#

# ConsumerGroupReplicationUpdateTypeDef definition

class ConsumerGroupReplicationUpdateTypeDef(TypedDict):
    ConsumerGroupsToExclude: Sequence[str],
    ConsumerGroupsToReplicate: Sequence[str],
    DetectAndCopyNewConsumerGroups: bool,
    SynchroniseConsumerGroupOffsets: bool,

ControllerNodeInfoTypeDef#

# ControllerNodeInfoTypeDef definition

class ControllerNodeInfoTypeDef(TypedDict):
    Endpoints: NotRequired[list[str]],

CreateVpcConnectionRequestRequestTypeDef#

# CreateVpcConnectionRequestRequestTypeDef definition

class CreateVpcConnectionRequestRequestTypeDef(TypedDict):
    TargetClusterArn: str,
    Authentication: str,
    VpcId: str,
    ClientSubnets: Sequence[str],
    SecurityGroups: Sequence[str],
    Tags: NotRequired[Mapping[str, str]],

DeleteClusterPolicyRequestRequestTypeDef#

# DeleteClusterPolicyRequestRequestTypeDef definition

class DeleteClusterPolicyRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

DeleteClusterRequestRequestTypeDef#

# DeleteClusterRequestRequestTypeDef definition

class DeleteClusterRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: NotRequired[str],

DeleteConfigurationRequestRequestTypeDef#

# DeleteConfigurationRequestRequestTypeDef definition

class DeleteConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,

DeleteReplicatorRequestRequestTypeDef#

# DeleteReplicatorRequestRequestTypeDef definition

class DeleteReplicatorRequestRequestTypeDef(TypedDict):
    ReplicatorArn: str,
    CurrentVersion: NotRequired[str],

DeleteVpcConnectionRequestRequestTypeDef#

# DeleteVpcConnectionRequestRequestTypeDef definition

class DeleteVpcConnectionRequestRequestTypeDef(TypedDict):
    Arn: str,

DescribeClusterOperationRequestRequestTypeDef#

# DescribeClusterOperationRequestRequestTypeDef definition

class DescribeClusterOperationRequestRequestTypeDef(TypedDict):
    ClusterOperationArn: str,

DescribeClusterOperationV2RequestRequestTypeDef#

# DescribeClusterOperationV2RequestRequestTypeDef definition

class DescribeClusterOperationV2RequestRequestTypeDef(TypedDict):
    ClusterOperationArn: str,

DescribeClusterRequestRequestTypeDef#

# DescribeClusterRequestRequestTypeDef definition

class DescribeClusterRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

DescribeClusterV2RequestRequestTypeDef#

# DescribeClusterV2RequestRequestTypeDef definition

class DescribeClusterV2RequestRequestTypeDef(TypedDict):
    ClusterArn: str,

DescribeConfigurationRequestRequestTypeDef#

# DescribeConfigurationRequestRequestTypeDef definition

class DescribeConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,

DescribeConfigurationRevisionRequestRequestTypeDef#

# DescribeConfigurationRevisionRequestRequestTypeDef definition

class DescribeConfigurationRevisionRequestRequestTypeDef(TypedDict):
    Arn: str,
    Revision: int,

DescribeReplicatorRequestRequestTypeDef#

# DescribeReplicatorRequestRequestTypeDef definition

class DescribeReplicatorRequestRequestTypeDef(TypedDict):
    ReplicatorArn: str,

ReplicationStateInfoTypeDef#

# ReplicationStateInfoTypeDef definition

class ReplicationStateInfoTypeDef(TypedDict):
    Code: NotRequired[str],
    Message: NotRequired[str],

DescribeVpcConnectionRequestRequestTypeDef#

# DescribeVpcConnectionRequestRequestTypeDef definition

class DescribeVpcConnectionRequestRequestTypeDef(TypedDict):
    Arn: str,

EncryptionAtRestTypeDef#

# EncryptionAtRestTypeDef definition

class EncryptionAtRestTypeDef(TypedDict):
    DataVolumeKMSKeyId: str,

EncryptionInTransitTypeDef#

# EncryptionInTransitTypeDef definition

class EncryptionInTransitTypeDef(TypedDict):
    ClientBroker: NotRequired[ClientBrokerType],  # (1)
    InCluster: NotRequired[bool],
  1. See ClientBrokerType

GetBootstrapBrokersRequestRequestTypeDef#

# GetBootstrapBrokersRequestRequestTypeDef definition

class GetBootstrapBrokersRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

GetClusterPolicyRequestRequestTypeDef#

# GetClusterPolicyRequestRequestTypeDef definition

class GetClusterPolicyRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

GetCompatibleKafkaVersionsRequestRequestTypeDef#

# GetCompatibleKafkaVersionsRequestRequestTypeDef definition

class GetCompatibleKafkaVersionsRequestRequestTypeDef(TypedDict):
    ClusterArn: NotRequired[str],

IamTypeDef#

# IamTypeDef definition

class IamTypeDef(TypedDict):
    Enabled: NotRequired[bool],

JmxExporterInfoTypeDef#

# JmxExporterInfoTypeDef definition

class JmxExporterInfoTypeDef(TypedDict):
    EnabledInBroker: bool,

JmxExporterTypeDef#

# JmxExporterTypeDef definition

class JmxExporterTypeDef(TypedDict):
    EnabledInBroker: bool,

KafkaClusterClientVpcConfigOutputTypeDef#

# KafkaClusterClientVpcConfigOutputTypeDef definition

class KafkaClusterClientVpcConfigOutputTypeDef(TypedDict):
    SubnetIds: list[str],
    SecurityGroupIds: NotRequired[list[str]],

KafkaClusterClientVpcConfigTypeDef#

# KafkaClusterClientVpcConfigTypeDef definition

class KafkaClusterClientVpcConfigTypeDef(TypedDict):
    SubnetIds: Sequence[str],
    SecurityGroupIds: NotRequired[Sequence[str]],

KafkaVersionTypeDef#

# KafkaVersionTypeDef definition

class KafkaVersionTypeDef(TypedDict):
    Version: NotRequired[str],
    Status: NotRequired[KafkaVersionStatusType],  # (1)
  1. See KafkaVersionStatusType

PaginatorConfigTypeDef#

# PaginatorConfigTypeDef definition

class PaginatorConfigTypeDef(TypedDict):
    MaxItems: NotRequired[int],
    PageSize: NotRequired[int],
    StartingToken: NotRequired[str],

ListClientVpcConnectionsRequestRequestTypeDef#

# ListClientVpcConnectionsRequestRequestTypeDef definition

class ListClientVpcConnectionsRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListClusterOperationsRequestRequestTypeDef#

# ListClusterOperationsRequestRequestTypeDef definition

class ListClusterOperationsRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListClusterOperationsV2RequestRequestTypeDef#

# ListClusterOperationsV2RequestRequestTypeDef definition

class ListClusterOperationsV2RequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListClustersRequestRequestTypeDef#

# ListClustersRequestRequestTypeDef definition

class ListClustersRequestRequestTypeDef(TypedDict):
    ClusterNameFilter: NotRequired[str],
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListClustersV2RequestRequestTypeDef#

# ListClustersV2RequestRequestTypeDef definition

class ListClustersV2RequestRequestTypeDef(TypedDict):
    ClusterNameFilter: NotRequired[str],
    ClusterTypeFilter: NotRequired[str],
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListConfigurationRevisionsRequestRequestTypeDef#

# ListConfigurationRevisionsRequestRequestTypeDef definition

class ListConfigurationRevisionsRequestRequestTypeDef(TypedDict):
    Arn: str,
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListConfigurationsRequestRequestTypeDef#

# ListConfigurationsRequestRequestTypeDef definition

class ListConfigurationsRequestRequestTypeDef(TypedDict):
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListKafkaVersionsRequestRequestTypeDef#

# ListKafkaVersionsRequestRequestTypeDef definition

class ListKafkaVersionsRequestRequestTypeDef(TypedDict):
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListNodesRequestRequestTypeDef#

# ListNodesRequestRequestTypeDef definition

class ListNodesRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListReplicatorsRequestRequestTypeDef#

# ListReplicatorsRequestRequestTypeDef definition

class ListReplicatorsRequestRequestTypeDef(TypedDict):
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],
    ReplicatorNameFilter: NotRequired[str],

ListScramSecretsRequestRequestTypeDef#

# ListScramSecretsRequestRequestTypeDef definition

class ListScramSecretsRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

ListTagsForResourceRequestRequestTypeDef#

# ListTagsForResourceRequestRequestTypeDef definition

class ListTagsForResourceRequestRequestTypeDef(TypedDict):
    ResourceArn: str,

ListVpcConnectionsRequestRequestTypeDef#

# ListVpcConnectionsRequestRequestTypeDef definition

class ListVpcConnectionsRequestRequestTypeDef(TypedDict):
    MaxResults: NotRequired[int],
    NextToken: NotRequired[str],

VpcConnectionTypeDef#

# VpcConnectionTypeDef definition

class VpcConnectionTypeDef(TypedDict):
    VpcConnectionArn: str,
    TargetClusterArn: str,
    CreationTime: NotRequired[datetime],
    Authentication: NotRequired[str],
    VpcId: NotRequired[str],
    State: NotRequired[VpcConnectionStateType],  # (1)
  1. See VpcConnectionStateType

NodeExporterInfoTypeDef#

# NodeExporterInfoTypeDef definition

class NodeExporterInfoTypeDef(TypedDict):
    EnabledInBroker: bool,

NodeExporterTypeDef#

# NodeExporterTypeDef definition

class NodeExporterTypeDef(TypedDict):
    EnabledInBroker: bool,

ZookeeperNodeInfoTypeDef#

# ZookeeperNodeInfoTypeDef definition

class ZookeeperNodeInfoTypeDef(TypedDict):
    AttachedENIId: NotRequired[str],
    ClientVpcIpAddress: NotRequired[str],
    Endpoints: NotRequired[list[str]],
    ZookeeperId: NotRequired[float],
    ZookeeperVersion: NotRequired[str],

PutClusterPolicyRequestRequestTypeDef#

# PutClusterPolicyRequestRequestTypeDef definition

class PutClusterPolicyRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    Policy: str,
    CurrentVersion: NotRequired[str],

RebootBrokerRequestRequestTypeDef#

# RebootBrokerRequestRequestTypeDef definition

class RebootBrokerRequestRequestTypeDef(TypedDict):
    BrokerIds: Sequence[str],
    ClusterArn: str,

RejectClientVpcConnectionRequestRequestTypeDef#

# RejectClientVpcConnectionRequestRequestTypeDef definition

class RejectClientVpcConnectionRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    VpcConnectionArn: str,

ReplicationInfoSummaryTypeDef#

# ReplicationInfoSummaryTypeDef definition

class ReplicationInfoSummaryTypeDef(TypedDict):
    SourceKafkaClusterAlias: NotRequired[str],
    TargetKafkaClusterAlias: NotRequired[str],

ReplicationStartingPositionTypeDef#

# ReplicationStartingPositionTypeDef definition

class ReplicationStartingPositionTypeDef(TypedDict):
    Type: NotRequired[ReplicationStartingPositionTypeType],  # (1)
  1. See ReplicationStartingPositionTypeType

ReplicationTopicNameConfigurationTypeDef#

# ReplicationTopicNameConfigurationTypeDef definition

class ReplicationTopicNameConfigurationTypeDef(TypedDict):
    Type: NotRequired[ReplicationTopicNameConfigurationTypeType],  # (1)
  1. See ReplicationTopicNameConfigurationTypeType

ScramTypeDef#

# ScramTypeDef definition

class ScramTypeDef(TypedDict):
    Enabled: NotRequired[bool],

VpcConfigOutputTypeDef#

# VpcConfigOutputTypeDef definition

class VpcConfigOutputTypeDef(TypedDict):
    SubnetIds: list[str],
    SecurityGroupIds: NotRequired[list[str]],

TagResourceRequestRequestTypeDef#

# TagResourceRequestRequestTypeDef definition

class TagResourceRequestRequestTypeDef(TypedDict):
    ResourceArn: str,
    Tags: Mapping[str, str],

TlsTypeDef#

# TlsTypeDef definition

class TlsTypeDef(TypedDict):
    CertificateAuthorityArnList: NotRequired[Sequence[str]],
    Enabled: NotRequired[bool],

TopicReplicationUpdateTypeDef#

# TopicReplicationUpdateTypeDef definition

class TopicReplicationUpdateTypeDef(TypedDict):
    CopyAccessControlListsForTopics: bool,
    CopyTopicConfigurations: bool,
    DetectAndCopyNewTopics: bool,
    TopicsToExclude: Sequence[str],
    TopicsToReplicate: Sequence[str],

UntagResourceRequestRequestTypeDef#

# UntagResourceRequestRequestTypeDef definition

class UntagResourceRequestRequestTypeDef(TypedDict):
    ResourceArn: str,
    TagKeys: Sequence[str],

UpdateBrokerCountRequestRequestTypeDef#

# UpdateBrokerCountRequestRequestTypeDef definition

class UpdateBrokerCountRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    TargetNumberOfBrokerNodes: int,

UpdateBrokerTypeRequestRequestTypeDef#

# UpdateBrokerTypeRequestRequestTypeDef definition

class UpdateBrokerTypeRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    TargetInstanceType: str,

UserIdentityTypeDef#

# UserIdentityTypeDef definition

class UserIdentityTypeDef(TypedDict):
    Type: NotRequired[UserIdentityTypeType],  # (1)
    PrincipalId: NotRequired[str],
  1. See UserIdentityTypeType

VpcConfigTypeDef#

# VpcConfigTypeDef definition

class VpcConfigTypeDef(TypedDict):
    SubnetIds: Sequence[str],
    SecurityGroupIds: NotRequired[Sequence[str]],

VpcConnectivityTlsTypeDef#

# VpcConnectivityTlsTypeDef definition

class VpcConnectivityTlsTypeDef(TypedDict):
    Enabled: NotRequired[bool],

VpcConnectivityIamTypeDef#

# VpcConnectivityIamTypeDef definition

class VpcConnectivityIamTypeDef(TypedDict):
    Enabled: NotRequired[bool],

VpcConnectivityScramTypeDef#

# VpcConnectivityScramTypeDef definition

class VpcConnectivityScramTypeDef(TypedDict):
    Enabled: NotRequired[bool],

KafkaClusterSummaryTypeDef#

# KafkaClusterSummaryTypeDef definition

class KafkaClusterSummaryTypeDef(TypedDict):
    AmazonMskCluster: NotRequired[AmazonMskClusterTypeDef],  # (1)
    KafkaClusterAlias: NotRequired[str],
  1. See AmazonMskClusterTypeDef

CreateClusterResponseTypeDef#

# CreateClusterResponseTypeDef definition

class CreateClusterResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterName: str,
    State: ClusterStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterStateType
  2. See ResponseMetadataTypeDef

CreateClusterV2ResponseTypeDef#

# CreateClusterV2ResponseTypeDef definition

class CreateClusterV2ResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterName: str,
    State: ClusterStateType,  # (1)
    ClusterType: ClusterTypeType,  # (2)
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See ClusterStateType
  2. See ClusterTypeType
  3. See ResponseMetadataTypeDef

CreateReplicatorResponseTypeDef#

# CreateReplicatorResponseTypeDef definition

class CreateReplicatorResponseTypeDef(TypedDict):
    ReplicatorArn: str,
    ReplicatorName: str,
    ReplicatorState: ReplicatorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ReplicatorStateType
  2. See ResponseMetadataTypeDef

CreateVpcConnectionResponseTypeDef#

# CreateVpcConnectionResponseTypeDef definition

class CreateVpcConnectionResponseTypeDef(TypedDict):
    VpcConnectionArn: str,
    State: VpcConnectionStateType,  # (1)
    Authentication: str,
    VpcId: str,
    ClientSubnets: list[str],
    SecurityGroups: list[str],
    CreationTime: datetime,
    Tags: dict[str, str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See VpcConnectionStateType
  2. See ResponseMetadataTypeDef

DeleteClusterResponseTypeDef#

# DeleteClusterResponseTypeDef definition

class DeleteClusterResponseTypeDef(TypedDict):
    ClusterArn: str,
    State: ClusterStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterStateType
  2. See ResponseMetadataTypeDef

DeleteConfigurationResponseTypeDef#

# DeleteConfigurationResponseTypeDef definition

class DeleteConfigurationResponseTypeDef(TypedDict):
    Arn: str,
    State: ConfigurationStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConfigurationStateType
  2. See ResponseMetadataTypeDef

DeleteReplicatorResponseTypeDef#

# DeleteReplicatorResponseTypeDef definition

class DeleteReplicatorResponseTypeDef(TypedDict):
    ReplicatorArn: str,
    ReplicatorState: ReplicatorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ReplicatorStateType
  2. See ResponseMetadataTypeDef

DeleteVpcConnectionResponseTypeDef#

# DeleteVpcConnectionResponseTypeDef definition

class DeleteVpcConnectionResponseTypeDef(TypedDict):
    VpcConnectionArn: str,
    State: VpcConnectionStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See VpcConnectionStateType
  2. See ResponseMetadataTypeDef

DescribeConfigurationRevisionResponseTypeDef#

# DescribeConfigurationRevisionResponseTypeDef definition

class DescribeConfigurationRevisionResponseTypeDef(TypedDict):
    Arn: str,
    CreationTime: datetime,
    Description: str,
    Revision: int,
    ServerProperties: bytes,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

DescribeVpcConnectionResponseTypeDef#

# DescribeVpcConnectionResponseTypeDef definition

class DescribeVpcConnectionResponseTypeDef(TypedDict):
    VpcConnectionArn: str,
    TargetClusterArn: str,
    State: VpcConnectionStateType,  # (1)
    Authentication: str,
    VpcId: str,
    Subnets: list[str],
    SecurityGroups: list[str],
    CreationTime: datetime,
    Tags: dict[str, str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See VpcConnectionStateType
  2. See ResponseMetadataTypeDef

EmptyResponseMetadataTypeDef#

# EmptyResponseMetadataTypeDef definition

class EmptyResponseMetadataTypeDef(TypedDict):
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

GetBootstrapBrokersResponseTypeDef#

# GetBootstrapBrokersResponseTypeDef definition

class GetBootstrapBrokersResponseTypeDef(TypedDict):
    BootstrapBrokerString: str,
    BootstrapBrokerStringTls: str,
    BootstrapBrokerStringSaslScram: str,
    BootstrapBrokerStringSaslIam: str,
    BootstrapBrokerStringPublicTls: str,
    BootstrapBrokerStringPublicSaslScram: str,
    BootstrapBrokerStringPublicSaslIam: str,
    BootstrapBrokerStringVpcConnectivityTls: str,
    BootstrapBrokerStringVpcConnectivitySaslScram: str,
    BootstrapBrokerStringVpcConnectivitySaslIam: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

GetClusterPolicyResponseTypeDef#

# GetClusterPolicyResponseTypeDef definition

class GetClusterPolicyResponseTypeDef(TypedDict):
    CurrentVersion: str,
    Policy: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

ListScramSecretsResponseTypeDef#

# ListScramSecretsResponseTypeDef definition

class ListScramSecretsResponseTypeDef(TypedDict):
    SecretArnList: list[str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
    NextToken: NotRequired[str],
  1. See ResponseMetadataTypeDef

ListTagsForResourceResponseTypeDef#

# ListTagsForResourceResponseTypeDef definition

class ListTagsForResourceResponseTypeDef(TypedDict):
    Tags: dict[str, str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

PutClusterPolicyResponseTypeDef#

# PutClusterPolicyResponseTypeDef definition

class PutClusterPolicyResponseTypeDef(TypedDict):
    CurrentVersion: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

RebootBrokerResponseTypeDef#

# RebootBrokerResponseTypeDef definition

class RebootBrokerResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateBrokerCountResponseTypeDef#

# UpdateBrokerCountResponseTypeDef definition

class UpdateBrokerCountResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateBrokerStorageResponseTypeDef#

# UpdateBrokerStorageResponseTypeDef definition

class UpdateBrokerStorageResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateBrokerTypeResponseTypeDef#

# UpdateBrokerTypeResponseTypeDef definition

class UpdateBrokerTypeResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateClusterConfigurationResponseTypeDef#

# UpdateClusterConfigurationResponseTypeDef definition

class UpdateClusterConfigurationResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateClusterKafkaVersionResponseTypeDef#

# UpdateClusterKafkaVersionResponseTypeDef definition

class UpdateClusterKafkaVersionResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateConnectivityResponseTypeDef#

# UpdateConnectivityResponseTypeDef definition

class UpdateConnectivityResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateMonitoringResponseTypeDef#

# UpdateMonitoringResponseTypeDef definition

class UpdateMonitoringResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateReplicationInfoResponseTypeDef#

# UpdateReplicationInfoResponseTypeDef definition

class UpdateReplicationInfoResponseTypeDef(TypedDict):
    ReplicatorArn: str,
    ReplicatorState: ReplicatorStateType,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ReplicatorStateType
  2. See ResponseMetadataTypeDef

UpdateSecurityResponseTypeDef#

# UpdateSecurityResponseTypeDef definition

class UpdateSecurityResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

UpdateStorageResponseTypeDef#

# UpdateStorageResponseTypeDef definition

class UpdateStorageResponseTypeDef(TypedDict):
    ClusterArn: str,
    ClusterOperationArn: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  1. See ResponseMetadataTypeDef

BatchAssociateScramSecretResponseTypeDef#

# BatchAssociateScramSecretResponseTypeDef definition

class BatchAssociateScramSecretResponseTypeDef(TypedDict):
    ClusterArn: str,
    UnprocessedScramSecrets: list[UnprocessedScramSecretTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See UnprocessedScramSecretTypeDef
  2. See ResponseMetadataTypeDef

BatchDisassociateScramSecretResponseTypeDef#

# BatchDisassociateScramSecretResponseTypeDef definition

class BatchDisassociateScramSecretResponseTypeDef(TypedDict):
    ClusterArn: str,
    UnprocessedScramSecrets: list[UnprocessedScramSecretTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See UnprocessedScramSecretTypeDef
  2. See ResponseMetadataTypeDef

CreateConfigurationRequestRequestTypeDef#

# CreateConfigurationRequestRequestTypeDef definition

class CreateConfigurationRequestRequestTypeDef(TypedDict):
    Name: str,
    ServerProperties: BlobTypeDef,
    Description: NotRequired[str],
    KafkaVersions: NotRequired[Sequence[str]],

UpdateConfigurationRequestRequestTypeDef#

# UpdateConfigurationRequestRequestTypeDef definition

class UpdateConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,
    ServerProperties: BlobTypeDef,
    Description: NotRequired[str],

BrokerEBSVolumeInfoTypeDef#

# BrokerEBSVolumeInfoTypeDef definition

class BrokerEBSVolumeInfoTypeDef(TypedDict):
    KafkaBrokerNodeId: str,
    ProvisionedThroughput: NotRequired[ProvisionedThroughputTypeDef],  # (1)
    VolumeSizeGB: NotRequired[int],
  1. See ProvisionedThroughputTypeDef

EBSStorageInfoTypeDef#

# EBSStorageInfoTypeDef definition

class EBSStorageInfoTypeDef(TypedDict):
    ProvisionedThroughput: NotRequired[ProvisionedThroughputTypeDef],  # (1)
    VolumeSize: NotRequired[int],
  1. See ProvisionedThroughputTypeDef

UpdateStorageRequestRequestTypeDef#

# UpdateStorageRequestRequestTypeDef definition

class UpdateStorageRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    ProvisionedThroughput: NotRequired[ProvisionedThroughputTypeDef],  # (1)
    StorageMode: NotRequired[StorageModeType],  # (2)
    VolumeSizeGB: NotRequired[int],
  1. See ProvisionedThroughputTypeDef
  2. See StorageModeType

BrokerLogsTypeDef#

# BrokerLogsTypeDef definition

class BrokerLogsTypeDef(TypedDict):
    CloudWatchLogs: NotRequired[CloudWatchLogsTypeDef],  # (1)
    Firehose: NotRequired[FirehoseTypeDef],  # (2)
    S3: NotRequired[S3TypeDef],  # (3)
  1. See CloudWatchLogsTypeDef
  2. See FirehoseTypeDef
  3. See S3TypeDef

BrokerNodeInfoTypeDef#

# BrokerNodeInfoTypeDef definition

class BrokerNodeInfoTypeDef(TypedDict):
    AttachedENIId: NotRequired[str],
    BrokerId: NotRequired[float],
    ClientSubnet: NotRequired[str],
    ClientVpcIpAddress: NotRequired[str],
    CurrentBrokerSoftwareInfo: NotRequired[BrokerSoftwareInfoTypeDef],  # (1)
    Endpoints: NotRequired[list[str]],
  1. See BrokerSoftwareInfoTypeDef

ListClientVpcConnectionsResponseTypeDef#

# ListClientVpcConnectionsResponseTypeDef definition

class ListClientVpcConnectionsResponseTypeDef(TypedDict):
    ClientVpcConnections: list[ClientVpcConnectionTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ClientVpcConnectionTypeDef
  2. See ResponseMetadataTypeDef

ClusterOperationStepTypeDef#

# ClusterOperationStepTypeDef definition

class ClusterOperationStepTypeDef(TypedDict):
    StepInfo: NotRequired[ClusterOperationStepInfoTypeDef],  # (1)
    StepName: NotRequired[str],
  1. See ClusterOperationStepInfoTypeDef

ListClusterOperationsV2ResponseTypeDef#

# ListClusterOperationsV2ResponseTypeDef definition

class ListClusterOperationsV2ResponseTypeDef(TypedDict):
    ClusterOperationInfoList: list[ClusterOperationV2SummaryTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ClusterOperationV2SummaryTypeDef
  2. See ResponseMetadataTypeDef

GetCompatibleKafkaVersionsResponseTypeDef#

# GetCompatibleKafkaVersionsResponseTypeDef definition

class GetCompatibleKafkaVersionsResponseTypeDef(TypedDict):
    CompatibleKafkaVersions: list[CompatibleKafkaVersionTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See CompatibleKafkaVersionTypeDef
  2. See ResponseMetadataTypeDef

UpdateClusterConfigurationRequestRequestTypeDef#

# UpdateClusterConfigurationRequestRequestTypeDef definition

class UpdateClusterConfigurationRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    ConfigurationInfo: ConfigurationInfoTypeDef,  # (1)
    CurrentVersion: str,
  1. See ConfigurationInfoTypeDef

UpdateClusterKafkaVersionRequestRequestTypeDef#

# UpdateClusterKafkaVersionRequestRequestTypeDef definition

class UpdateClusterKafkaVersionRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    TargetKafkaVersion: str,
    ConfigurationInfo: NotRequired[ConfigurationInfoTypeDef],  # (1)
  1. See ConfigurationInfoTypeDef

ConfigurationTypeDef#

# ConfigurationTypeDef definition

class ConfigurationTypeDef(TypedDict):
    Arn: str,
    CreationTime: datetime,
    Description: str,
    KafkaVersions: list[str],
    LatestRevision: ConfigurationRevisionTypeDef,  # (1)
    Name: str,
    State: ConfigurationStateType,  # (2)
  1. See ConfigurationRevisionTypeDef
  2. See ConfigurationStateType

CreateConfigurationResponseTypeDef#

# CreateConfigurationResponseTypeDef definition

class CreateConfigurationResponseTypeDef(TypedDict):
    Arn: str,
    CreationTime: datetime,
    LatestRevision: ConfigurationRevisionTypeDef,  # (1)
    Name: str,
    State: ConfigurationStateType,  # (2)
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See ConfigurationRevisionTypeDef
  2. See ConfigurationStateType
  3. See ResponseMetadataTypeDef

DescribeConfigurationResponseTypeDef#

# DescribeConfigurationResponseTypeDef definition

class DescribeConfigurationResponseTypeDef(TypedDict):
    Arn: str,
    CreationTime: datetime,
    Description: str,
    KafkaVersions: list[str],
    LatestRevision: ConfigurationRevisionTypeDef,  # (1)
    Name: str,
    State: ConfigurationStateType,  # (2)
    ResponseMetadata: ResponseMetadataTypeDef,  # (3)
  1. See ConfigurationRevisionTypeDef
  2. See ConfigurationStateType
  3. See ResponseMetadataTypeDef

ListConfigurationRevisionsResponseTypeDef#

# ListConfigurationRevisionsResponseTypeDef definition

class ListConfigurationRevisionsResponseTypeDef(TypedDict):
    Revisions: list[ConfigurationRevisionTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ConfigurationRevisionTypeDef
  2. See ResponseMetadataTypeDef

UpdateConfigurationResponseTypeDef#

# UpdateConfigurationResponseTypeDef definition

class UpdateConfigurationResponseTypeDef(TypedDict):
    Arn: str,
    LatestRevision: ConfigurationRevisionTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ConfigurationRevisionTypeDef
  2. See ResponseMetadataTypeDef

EncryptionInfoTypeDef#

# EncryptionInfoTypeDef definition

class EncryptionInfoTypeDef(TypedDict):
    EncryptionAtRest: NotRequired[EncryptionAtRestTypeDef],  # (1)
    EncryptionInTransit: NotRequired[EncryptionInTransitTypeDef],  # (2)
  1. See EncryptionAtRestTypeDef
  2. See EncryptionInTransitTypeDef

ServerlessSaslTypeDef#

# ServerlessSaslTypeDef definition

class ServerlessSaslTypeDef(TypedDict):
    Iam: NotRequired[IamTypeDef],  # (1)
  1. See IamTypeDef

KafkaClusterDescriptionTypeDef#

# KafkaClusterDescriptionTypeDef definition

class KafkaClusterDescriptionTypeDef(TypedDict):
    AmazonMskCluster: NotRequired[AmazonMskClusterTypeDef],  # (1)
    KafkaClusterAlias: NotRequired[str],
    VpcConfig: NotRequired[KafkaClusterClientVpcConfigOutputTypeDef],  # (2)
  1. See AmazonMskClusterTypeDef
  2. See KafkaClusterClientVpcConfigOutputTypeDef

ListKafkaVersionsResponseTypeDef#

# ListKafkaVersionsResponseTypeDef definition

class ListKafkaVersionsResponseTypeDef(TypedDict):
    KafkaVersions: list[KafkaVersionTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See KafkaVersionTypeDef
  2. See ResponseMetadataTypeDef

ListClientVpcConnectionsRequestPaginateTypeDef#

# ListClientVpcConnectionsRequestPaginateTypeDef definition

class ListClientVpcConnectionsRequestPaginateTypeDef(TypedDict):
    ClusterArn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListClusterOperationsRequestPaginateTypeDef#

# ListClusterOperationsRequestPaginateTypeDef definition

class ListClusterOperationsRequestPaginateTypeDef(TypedDict):
    ClusterArn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListClusterOperationsV2RequestPaginateTypeDef#

# ListClusterOperationsV2RequestPaginateTypeDef definition

class ListClusterOperationsV2RequestPaginateTypeDef(TypedDict):
    ClusterArn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListClustersRequestPaginateTypeDef#

# ListClustersRequestPaginateTypeDef definition

class ListClustersRequestPaginateTypeDef(TypedDict):
    ClusterNameFilter: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListClustersV2RequestPaginateTypeDef#

# ListClustersV2RequestPaginateTypeDef definition

class ListClustersV2RequestPaginateTypeDef(TypedDict):
    ClusterNameFilter: NotRequired[str],
    ClusterTypeFilter: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListConfigurationRevisionsRequestPaginateTypeDef#

# ListConfigurationRevisionsRequestPaginateTypeDef definition

class ListConfigurationRevisionsRequestPaginateTypeDef(TypedDict):
    Arn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListConfigurationsRequestPaginateTypeDef#

# ListConfigurationsRequestPaginateTypeDef definition

class ListConfigurationsRequestPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListKafkaVersionsRequestPaginateTypeDef#

# ListKafkaVersionsRequestPaginateTypeDef definition

class ListKafkaVersionsRequestPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListNodesRequestPaginateTypeDef#

# ListNodesRequestPaginateTypeDef definition

class ListNodesRequestPaginateTypeDef(TypedDict):
    ClusterArn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListReplicatorsRequestPaginateTypeDef#

# ListReplicatorsRequestPaginateTypeDef definition

class ListReplicatorsRequestPaginateTypeDef(TypedDict):
    ReplicatorNameFilter: NotRequired[str],
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListScramSecretsRequestPaginateTypeDef#

# ListScramSecretsRequestPaginateTypeDef definition

class ListScramSecretsRequestPaginateTypeDef(TypedDict):
    ClusterArn: str,
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListVpcConnectionsRequestPaginateTypeDef#

# ListVpcConnectionsRequestPaginateTypeDef definition

class ListVpcConnectionsRequestPaginateTypeDef(TypedDict):
    PaginationConfig: NotRequired[PaginatorConfigTypeDef],  # (1)
  1. See PaginatorConfigTypeDef

ListVpcConnectionsResponseTypeDef#

# ListVpcConnectionsResponseTypeDef definition

class ListVpcConnectionsResponseTypeDef(TypedDict):
    VpcConnections: list[VpcConnectionTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See VpcConnectionTypeDef
  2. See ResponseMetadataTypeDef

PrometheusInfoTypeDef#

# PrometheusInfoTypeDef definition

class PrometheusInfoTypeDef(TypedDict):
    JmxExporter: NotRequired[JmxExporterInfoTypeDef],  # (1)
    NodeExporter: NotRequired[NodeExporterInfoTypeDef],  # (2)
  1. See JmxExporterInfoTypeDef
  2. See NodeExporterInfoTypeDef

PrometheusTypeDef#

# PrometheusTypeDef definition

class PrometheusTypeDef(TypedDict):
    JmxExporter: NotRequired[JmxExporterTypeDef],  # (1)
    NodeExporter: NotRequired[NodeExporterTypeDef],  # (2)
  1. See JmxExporterTypeDef
  2. See NodeExporterTypeDef

TopicReplicationOutputTypeDef#

# TopicReplicationOutputTypeDef definition

class TopicReplicationOutputTypeDef(TypedDict):
    TopicsToReplicate: list[str],
    CopyAccessControlListsForTopics: NotRequired[bool],
    CopyTopicConfigurations: NotRequired[bool],
    DetectAndCopyNewTopics: NotRequired[bool],
    StartingPosition: NotRequired[ReplicationStartingPositionTypeDef],  # (1)
    TopicNameConfiguration: NotRequired[ReplicationTopicNameConfigurationTypeDef],  # (2)
    TopicsToExclude: NotRequired[list[str]],
  1. See ReplicationStartingPositionTypeDef
  2. See ReplicationTopicNameConfigurationTypeDef

TopicReplicationTypeDef#

# TopicReplicationTypeDef definition

class TopicReplicationTypeDef(TypedDict):
    TopicsToReplicate: Sequence[str],
    CopyAccessControlListsForTopics: NotRequired[bool],
    CopyTopicConfigurations: NotRequired[bool],
    DetectAndCopyNewTopics: NotRequired[bool],
    StartingPosition: NotRequired[ReplicationStartingPositionTypeDef],  # (1)
    TopicNameConfiguration: NotRequired[ReplicationTopicNameConfigurationTypeDef],  # (2)
    TopicsToExclude: NotRequired[Sequence[str]],
  1. See ReplicationStartingPositionTypeDef
  2. See ReplicationTopicNameConfigurationTypeDef

SaslTypeDef#

# SaslTypeDef definition

class SaslTypeDef(TypedDict):
    Scram: NotRequired[ScramTypeDef],  # (1)
    Iam: NotRequired[IamTypeDef],  # (2)
  1. See ScramTypeDef
  2. See IamTypeDef

UpdateReplicationInfoRequestRequestTypeDef#

# UpdateReplicationInfoRequestRequestTypeDef definition

class UpdateReplicationInfoRequestRequestTypeDef(TypedDict):
    CurrentVersion: str,
    ReplicatorArn: str,
    SourceKafkaClusterArn: str,
    TargetKafkaClusterArn: str,
    ConsumerGroupReplication: NotRequired[ConsumerGroupReplicationUpdateTypeDef],  # (1)
    TopicReplication: NotRequired[TopicReplicationUpdateTypeDef],  # (2)
  1. See ConsumerGroupReplicationUpdateTypeDef
  2. See TopicReplicationUpdateTypeDef

VpcConnectionInfoServerlessTypeDef#

# VpcConnectionInfoServerlessTypeDef definition

class VpcConnectionInfoServerlessTypeDef(TypedDict):
    CreationTime: NotRequired[datetime],
    Owner: NotRequired[str],
    UserIdentity: NotRequired[UserIdentityTypeDef],  # (1)
    VpcConnectionArn: NotRequired[str],
  1. See UserIdentityTypeDef

VpcConnectionInfoTypeDef#

# VpcConnectionInfoTypeDef definition

class VpcConnectionInfoTypeDef(TypedDict):
    VpcConnectionArn: NotRequired[str],
    Owner: NotRequired[str],
    UserIdentity: NotRequired[UserIdentityTypeDef],  # (1)
    CreationTime: NotRequired[datetime],
  1. See UserIdentityTypeDef

VpcConnectivitySaslTypeDef#

# VpcConnectivitySaslTypeDef definition

class VpcConnectivitySaslTypeDef(TypedDict):
    Scram: NotRequired[VpcConnectivityScramTypeDef],  # (1)
    Iam: NotRequired[VpcConnectivityIamTypeDef],  # (2)
  1. See VpcConnectivityScramTypeDef
  2. See VpcConnectivityIamTypeDef

ReplicatorSummaryTypeDef#

# ReplicatorSummaryTypeDef definition

class ReplicatorSummaryTypeDef(TypedDict):
    CreationTime: NotRequired[datetime],
    CurrentVersion: NotRequired[str],
    IsReplicatorReference: NotRequired[bool],
    KafkaClustersSummary: NotRequired[list[KafkaClusterSummaryTypeDef]],  # (1)
    ReplicationInfoSummaryList: NotRequired[list[ReplicationInfoSummaryTypeDef]],  # (2)
    ReplicatorArn: NotRequired[str],
    ReplicatorName: NotRequired[str],
    ReplicatorResourceArn: NotRequired[str],
    ReplicatorState: NotRequired[ReplicatorStateType],  # (3)
  1. See KafkaClusterSummaryTypeDef
  2. See ReplicationInfoSummaryTypeDef
  3. See ReplicatorStateType

UpdateBrokerStorageRequestRequestTypeDef#

# UpdateBrokerStorageRequestRequestTypeDef definition

class UpdateBrokerStorageRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    TargetBrokerEBSVolumeInfo: Sequence[BrokerEBSVolumeInfoTypeDef],  # (1)
  1. See BrokerEBSVolumeInfoTypeDef

StorageInfoTypeDef#

# StorageInfoTypeDef definition

class StorageInfoTypeDef(TypedDict):
    EbsStorageInfo: NotRequired[EBSStorageInfoTypeDef],  # (1)
  1. See EBSStorageInfoTypeDef

LoggingInfoTypeDef#

# LoggingInfoTypeDef definition

class LoggingInfoTypeDef(TypedDict):
    BrokerLogs: BrokerLogsTypeDef,  # (1)
  1. See BrokerLogsTypeDef

NodeInfoTypeDef#

# NodeInfoTypeDef definition

class NodeInfoTypeDef(TypedDict):
    AddedToClusterTime: NotRequired[str],
    BrokerNodeInfo: NotRequired[BrokerNodeInfoTypeDef],  # (1)
    ControllerNodeInfo: NotRequired[ControllerNodeInfoTypeDef],  # (2)
    InstanceType: NotRequired[str],
    NodeARN: NotRequired[str],
    NodeType: NotRequired[NodeTypeType],  # (3)
    ZookeeperNodeInfo: NotRequired[ZookeeperNodeInfoTypeDef],  # (4)
  1. See BrokerNodeInfoTypeDef
  2. See ControllerNodeInfoTypeDef
  3. See NodeTypeType
  4. See ZookeeperNodeInfoTypeDef

ListConfigurationsResponseTypeDef#

# ListConfigurationsResponseTypeDef definition

class ListConfigurationsResponseTypeDef(TypedDict):
    Configurations: list[ConfigurationTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ConfigurationTypeDef
  2. See ResponseMetadataTypeDef

ServerlessClientAuthenticationTypeDef#

# ServerlessClientAuthenticationTypeDef definition

class ServerlessClientAuthenticationTypeDef(TypedDict):
    Sasl: NotRequired[ServerlessSaslTypeDef],  # (1)
  1. See ServerlessSaslTypeDef

KafkaClusterTypeDef#

# KafkaClusterTypeDef definition

class KafkaClusterTypeDef(TypedDict):
    AmazonMskCluster: AmazonMskClusterTypeDef,  # (1)
    VpcConfig: KafkaClusterClientVpcConfigUnionTypeDef,  # (2)
  1. See AmazonMskClusterTypeDef
  2. See KafkaClusterClientVpcConfigTypeDef KafkaClusterClientVpcConfigOutputTypeDef

OpenMonitoringInfoTypeDef#

# OpenMonitoringInfoTypeDef definition

class OpenMonitoringInfoTypeDef(TypedDict):
    Prometheus: PrometheusInfoTypeDef,  # (1)
  1. See PrometheusInfoTypeDef

OpenMonitoringTypeDef#

# OpenMonitoringTypeDef definition

class OpenMonitoringTypeDef(TypedDict):
    Prometheus: PrometheusTypeDef,  # (1)
  1. See PrometheusTypeDef

ReplicationInfoDescriptionTypeDef#

# ReplicationInfoDescriptionTypeDef definition

class ReplicationInfoDescriptionTypeDef(TypedDict):
    ConsumerGroupReplication: NotRequired[ConsumerGroupReplicationOutputTypeDef],  # (1)
    SourceKafkaClusterAlias: NotRequired[str],
    TargetCompressionType: NotRequired[TargetCompressionTypeType],  # (2)
    TargetKafkaClusterAlias: NotRequired[str],
    TopicReplication: NotRequired[TopicReplicationOutputTypeDef],  # (3)
  1. See ConsumerGroupReplicationOutputTypeDef
  2. See TargetCompressionTypeType
  3. See TopicReplicationOutputTypeDef

ClientAuthenticationOutputTypeDef#

# ClientAuthenticationOutputTypeDef definition

class ClientAuthenticationOutputTypeDef(TypedDict):
    Sasl: NotRequired[SaslTypeDef],  # (1)
    Tls: NotRequired[TlsOutputTypeDef],  # (2)
    Unauthenticated: NotRequired[UnauthenticatedTypeDef],  # (3)
  1. See SaslTypeDef
  2. See TlsOutputTypeDef
  3. See UnauthenticatedTypeDef

ClientAuthenticationTypeDef#

# ClientAuthenticationTypeDef definition

class ClientAuthenticationTypeDef(TypedDict):
    Sasl: NotRequired[SaslTypeDef],  # (1)
    Tls: NotRequired[TlsUnionTypeDef],  # (2)
    Unauthenticated: NotRequired[UnauthenticatedTypeDef],  # (3)
  1. See SaslTypeDef
  2. See TlsTypeDef TlsOutputTypeDef
  3. See UnauthenticatedTypeDef

ClusterOperationV2ServerlessTypeDef#

# ClusterOperationV2ServerlessTypeDef definition

class ClusterOperationV2ServerlessTypeDef(TypedDict):
    VpcConnectionInfo: NotRequired[VpcConnectionInfoServerlessTypeDef],  # (1)
  1. See VpcConnectionInfoServerlessTypeDef

VpcConnectivityClientAuthenticationTypeDef#

# VpcConnectivityClientAuthenticationTypeDef definition

class VpcConnectivityClientAuthenticationTypeDef(TypedDict):
    Sasl: NotRequired[VpcConnectivitySaslTypeDef],  # (1)
    Tls: NotRequired[VpcConnectivityTlsTypeDef],  # (2)
  1. See VpcConnectivitySaslTypeDef
  2. See VpcConnectivityTlsTypeDef

ListReplicatorsResponseTypeDef#

# ListReplicatorsResponseTypeDef definition

class ListReplicatorsResponseTypeDef(TypedDict):
    Replicators: list[ReplicatorSummaryTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ReplicatorSummaryTypeDef
  2. See ResponseMetadataTypeDef

ListNodesResponseTypeDef#

# ListNodesResponseTypeDef definition

class ListNodesResponseTypeDef(TypedDict):
    NodeInfoList: list[NodeInfoTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See NodeInfoTypeDef
  2. See ResponseMetadataTypeDef

ServerlessRequestTypeDef#

# ServerlessRequestTypeDef definition

class ServerlessRequestTypeDef(TypedDict):
    VpcConfigs: Sequence[VpcConfigUnionTypeDef],  # (1)
    ClientAuthentication: NotRequired[ServerlessClientAuthenticationTypeDef],  # (2)
  1. See VpcConfigTypeDef VpcConfigOutputTypeDef
  2. See ServerlessClientAuthenticationTypeDef

ServerlessTypeDef#

# ServerlessTypeDef definition

class ServerlessTypeDef(TypedDict):
    VpcConfigs: list[VpcConfigOutputTypeDef],  # (1)
    ClientAuthentication: NotRequired[ServerlessClientAuthenticationTypeDef],  # (2)
  1. See VpcConfigOutputTypeDef
  2. See ServerlessClientAuthenticationTypeDef

UpdateMonitoringRequestRequestTypeDef#

# UpdateMonitoringRequestRequestTypeDef definition

class UpdateMonitoringRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    EnhancedMonitoring: NotRequired[EnhancedMonitoringType],  # (1)
    OpenMonitoring: NotRequired[OpenMonitoringInfoTypeDef],  # (2)
    LoggingInfo: NotRequired[LoggingInfoTypeDef],  # (3)
  1. See EnhancedMonitoringType
  2. See OpenMonitoringInfoTypeDef
  3. See LoggingInfoTypeDef

DescribeReplicatorResponseTypeDef#

# DescribeReplicatorResponseTypeDef definition

class DescribeReplicatorResponseTypeDef(TypedDict):
    CreationTime: datetime,
    CurrentVersion: str,
    IsReplicatorReference: bool,
    KafkaClusters: list[KafkaClusterDescriptionTypeDef],  # (1)
    ReplicationInfoList: list[ReplicationInfoDescriptionTypeDef],  # (2)
    ReplicatorArn: str,
    ReplicatorDescription: str,
    ReplicatorName: str,
    ReplicatorResourceArn: str,
    ReplicatorState: ReplicatorStateType,  # (3)
    ServiceExecutionRoleArn: str,
    StateInfo: ReplicationStateInfoTypeDef,  # (4)
    Tags: dict[str, str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (5)
  1. See KafkaClusterDescriptionTypeDef
  2. See ReplicationInfoDescriptionTypeDef
  3. See ReplicatorStateType
  4. See ReplicationStateInfoTypeDef
  5. See ResponseMetadataTypeDef

ReplicationInfoTypeDef#

# ReplicationInfoTypeDef definition

class ReplicationInfoTypeDef(TypedDict):
    ConsumerGroupReplication: ConsumerGroupReplicationUnionTypeDef,  # (1)
    SourceKafkaClusterArn: str,
    TargetCompressionType: TargetCompressionTypeType,  # (2)
    TargetKafkaClusterArn: str,
    TopicReplication: TopicReplicationUnionTypeDef,  # (3)
  1. See ConsumerGroupReplicationTypeDef ConsumerGroupReplicationOutputTypeDef
  2. See TargetCompressionTypeType
  3. See TopicReplicationTypeDef TopicReplicationOutputTypeDef

UpdateSecurityRequestRequestTypeDef#

# UpdateSecurityRequestRequestTypeDef definition

class UpdateSecurityRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    CurrentVersion: str,
    ClientAuthentication: NotRequired[ClientAuthenticationTypeDef],  # (1)
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (2)
  1. See ClientAuthenticationTypeDef
  2. See EncryptionInfoTypeDef

VpcConnectivityTypeDef#

# VpcConnectivityTypeDef definition

class VpcConnectivityTypeDef(TypedDict):
    ClientAuthentication: NotRequired[VpcConnectivityClientAuthenticationTypeDef],  # (1)
  1. See VpcConnectivityClientAuthenticationTypeDef

CreateReplicatorRequestRequestTypeDef#

# CreateReplicatorRequestRequestTypeDef definition

class CreateReplicatorRequestRequestTypeDef(TypedDict):
    KafkaClusters: Sequence[KafkaClusterTypeDef],  # (1)
    ReplicationInfoList: Sequence[ReplicationInfoTypeDef],  # (2)
    ReplicatorName: str,
    ServiceExecutionRoleArn: str,
    Description: NotRequired[str],
    Tags: NotRequired[Mapping[str, str]],
  1. See KafkaClusterTypeDef
  2. See ReplicationInfoTypeDef

ConnectivityInfoTypeDef#

# ConnectivityInfoTypeDef definition

class ConnectivityInfoTypeDef(TypedDict):
    PublicAccess: NotRequired[PublicAccessTypeDef],  # (1)
    VpcConnectivity: NotRequired[VpcConnectivityTypeDef],  # (2)
  1. See PublicAccessTypeDef
  2. See VpcConnectivityTypeDef

BrokerNodeGroupInfoOutputTypeDef#

# BrokerNodeGroupInfoOutputTypeDef definition

class BrokerNodeGroupInfoOutputTypeDef(TypedDict):
    ClientSubnets: list[str],
    InstanceType: str,
    BrokerAZDistribution: NotRequired[BrokerAZDistributionType],  # (1)
    SecurityGroups: NotRequired[list[str]],
    StorageInfo: NotRequired[StorageInfoTypeDef],  # (2)
    ConnectivityInfo: NotRequired[ConnectivityInfoTypeDef],  # (3)
    ZoneIds: NotRequired[list[str]],
  1. See BrokerAZDistributionType
  2. See StorageInfoTypeDef
  3. See ConnectivityInfoTypeDef

BrokerNodeGroupInfoTypeDef#

# BrokerNodeGroupInfoTypeDef definition

class BrokerNodeGroupInfoTypeDef(TypedDict):
    ClientSubnets: Sequence[str],
    InstanceType: str,
    BrokerAZDistribution: NotRequired[BrokerAZDistributionType],  # (1)
    SecurityGroups: NotRequired[Sequence[str]],
    StorageInfo: NotRequired[StorageInfoTypeDef],  # (2)
    ConnectivityInfo: NotRequired[ConnectivityInfoTypeDef],  # (3)
    ZoneIds: NotRequired[Sequence[str]],
  1. See BrokerAZDistributionType
  2. See StorageInfoTypeDef
  3. See ConnectivityInfoTypeDef

MutableClusterInfoTypeDef#

# MutableClusterInfoTypeDef definition

class MutableClusterInfoTypeDef(TypedDict):
    BrokerEBSVolumeInfo: NotRequired[list[BrokerEBSVolumeInfoTypeDef]],  # (1)
    ConfigurationInfo: NotRequired[ConfigurationInfoTypeDef],  # (2)
    NumberOfBrokerNodes: NotRequired[int],
    EnhancedMonitoring: NotRequired[EnhancedMonitoringType],  # (3)
    OpenMonitoring: NotRequired[OpenMonitoringTypeDef],  # (4)
    KafkaVersion: NotRequired[str],
    LoggingInfo: NotRequired[LoggingInfoTypeDef],  # (5)
    InstanceType: NotRequired[str],
    ClientAuthentication: NotRequired[ClientAuthenticationOutputTypeDef],  # (6)
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (7)
    ConnectivityInfo: NotRequired[ConnectivityInfoTypeDef],  # (8)
    StorageMode: NotRequired[StorageModeType],  # (9)
    BrokerCountUpdateInfo: NotRequired[BrokerCountUpdateInfoTypeDef],  # (10)
  1. See BrokerEBSVolumeInfoTypeDef
  2. See ConfigurationInfoTypeDef
  3. See EnhancedMonitoringType
  4. See OpenMonitoringTypeDef
  5. See LoggingInfoTypeDef
  6. See ClientAuthenticationOutputTypeDef
  7. See EncryptionInfoTypeDef
  8. See ConnectivityInfoTypeDef
  9. See StorageModeType
  10. See BrokerCountUpdateInfoTypeDef

UpdateConnectivityRequestRequestTypeDef#

# UpdateConnectivityRequestRequestTypeDef definition

class UpdateConnectivityRequestRequestTypeDef(TypedDict):
    ClusterArn: str,
    ConnectivityInfo: ConnectivityInfoTypeDef,  # (1)
    CurrentVersion: str,
  1. See ConnectivityInfoTypeDef

ClusterInfoTypeDef#

# ClusterInfoTypeDef definition

class ClusterInfoTypeDef(TypedDict):
    ActiveOperationArn: NotRequired[str],
    BrokerNodeGroupInfo: NotRequired[BrokerNodeGroupInfoOutputTypeDef],  # (1)
    ClientAuthentication: NotRequired[ClientAuthenticationOutputTypeDef],  # (2)
    ClusterArn: NotRequired[str],
    ClusterName: NotRequired[str],
    CreationTime: NotRequired[datetime],
    CurrentBrokerSoftwareInfo: NotRequired[BrokerSoftwareInfoTypeDef],  # (3)
    CurrentVersion: NotRequired[str],
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (4)
    EnhancedMonitoring: NotRequired[EnhancedMonitoringType],  # (5)
    OpenMonitoring: NotRequired[OpenMonitoringTypeDef],  # (6)
    LoggingInfo: NotRequired[LoggingInfoTypeDef],  # (7)
    NumberOfBrokerNodes: NotRequired[int],
    State: NotRequired[ClusterStateType],  # (8)
    StateInfo: NotRequired[StateInfoTypeDef],  # (9)
    Tags: NotRequired[dict[str, str]],
    ZookeeperConnectString: NotRequired[str],
    ZookeeperConnectStringTls: NotRequired[str],
    StorageMode: NotRequired[StorageModeType],  # (10)
    CustomerActionStatus: NotRequired[CustomerActionStatusType],  # (11)
  1. See BrokerNodeGroupInfoOutputTypeDef
  2. See ClientAuthenticationOutputTypeDef
  3. See BrokerSoftwareInfoTypeDef
  4. See EncryptionInfoTypeDef
  5. See EnhancedMonitoringType
  6. See OpenMonitoringTypeDef
  7. See LoggingInfoTypeDef
  8. See ClusterStateType
  9. See StateInfoTypeDef
  10. See StorageModeType
  11. See CustomerActionStatusType

ProvisionedTypeDef#

# ProvisionedTypeDef definition

class ProvisionedTypeDef(TypedDict):
    BrokerNodeGroupInfo: BrokerNodeGroupInfoOutputTypeDef,  # (1)
    NumberOfBrokerNodes: int,
    CurrentBrokerSoftwareInfo: NotRequired[BrokerSoftwareInfoTypeDef],  # (2)
    ClientAuthentication: NotRequired[ClientAuthenticationOutputTypeDef],  # (3)
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (4)
    EnhancedMonitoring: NotRequired[EnhancedMonitoringType],  # (5)
    OpenMonitoring: NotRequired[OpenMonitoringInfoTypeDef],  # (6)
    LoggingInfo: NotRequired[LoggingInfoTypeDef],  # (7)
    ZookeeperConnectString: NotRequired[str],
    ZookeeperConnectStringTls: NotRequired[str],
    StorageMode: NotRequired[StorageModeType],  # (8)
    CustomerActionStatus: NotRequired[CustomerActionStatusType],  # (9)
  1. See BrokerNodeGroupInfoOutputTypeDef
  2. See BrokerSoftwareInfoTypeDef
  3. See ClientAuthenticationOutputTypeDef
  4. See EncryptionInfoTypeDef
  5. See EnhancedMonitoringType
  6. See OpenMonitoringInfoTypeDef
  7. See LoggingInfoTypeDef
  8. See StorageModeType
  9. See CustomerActionStatusType

CreateClusterRequestRequestTypeDef#

# CreateClusterRequestRequestTypeDef definition

class CreateClusterRequestRequestTypeDef(TypedDict):
    BrokerNodeGroupInfo: BrokerNodeGroupInfoTypeDef,  # (1)
    ClusterName: str,
    KafkaVersion: str,
    NumberOfBrokerNodes: int,
    ClientAuthentication: NotRequired[ClientAuthenticationTypeDef],  # (2)
    ConfigurationInfo: NotRequired[ConfigurationInfoTypeDef],  # (3)
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (4)
    EnhancedMonitoring: NotRequired[EnhancedMonitoringType],  # (5)
    OpenMonitoring: NotRequired[OpenMonitoringInfoTypeDef],  # (6)
    LoggingInfo: NotRequired[LoggingInfoTypeDef],  # (7)
    Tags: NotRequired[Mapping[str, str]],
    StorageMode: NotRequired[StorageModeType],  # (8)
  1. See BrokerNodeGroupInfoTypeDef
  2. See ClientAuthenticationTypeDef
  3. See ConfigurationInfoTypeDef
  4. See EncryptionInfoTypeDef
  5. See EnhancedMonitoringType
  6. See OpenMonitoringInfoTypeDef
  7. See LoggingInfoTypeDef
  8. See StorageModeType

ClusterOperationInfoTypeDef#

# ClusterOperationInfoTypeDef definition

class ClusterOperationInfoTypeDef(TypedDict):
    ClientRequestId: NotRequired[str],
    ClusterArn: NotRequired[str],
    CreationTime: NotRequired[datetime],
    EndTime: NotRequired[datetime],
    ErrorInfo: NotRequired[ErrorInfoTypeDef],  # (1)
    OperationArn: NotRequired[str],
    OperationState: NotRequired[str],
    OperationSteps: NotRequired[list[ClusterOperationStepTypeDef]],  # (2)
    OperationType: NotRequired[str],
    SourceClusterInfo: NotRequired[MutableClusterInfoTypeDef],  # (3)
    TargetClusterInfo: NotRequired[MutableClusterInfoTypeDef],  # (3)
    VpcConnectionInfo: NotRequired[VpcConnectionInfoTypeDef],  # (5)
  1. See ErrorInfoTypeDef
  2. See ClusterOperationStepTypeDef
  3. See MutableClusterInfoTypeDef
  4. See MutableClusterInfoTypeDef
  5. See VpcConnectionInfoTypeDef

ClusterOperationV2ProvisionedTypeDef#

# ClusterOperationV2ProvisionedTypeDef definition

class ClusterOperationV2ProvisionedTypeDef(TypedDict):
    OperationSteps: NotRequired[list[ClusterOperationStepTypeDef]],  # (1)
    SourceClusterInfo: NotRequired[MutableClusterInfoTypeDef],  # (2)
    TargetClusterInfo: NotRequired[MutableClusterInfoTypeDef],  # (2)
    VpcConnectionInfo: NotRequired[VpcConnectionInfoTypeDef],  # (4)
  1. See ClusterOperationStepTypeDef
  2. See MutableClusterInfoTypeDef
  3. See MutableClusterInfoTypeDef
  4. See VpcConnectionInfoTypeDef

DescribeClusterResponseTypeDef#

# DescribeClusterResponseTypeDef definition

class DescribeClusterResponseTypeDef(TypedDict):
    ClusterInfo: ClusterInfoTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterInfoTypeDef
  2. See ResponseMetadataTypeDef

ListClustersResponseTypeDef#

# ListClustersResponseTypeDef definition

class ListClustersResponseTypeDef(TypedDict):
    ClusterInfoList: list[ClusterInfoTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ClusterInfoTypeDef
  2. See ResponseMetadataTypeDef

ClusterTypeDef#

# ClusterTypeDef definition

class ClusterTypeDef(TypedDict):
    ActiveOperationArn: NotRequired[str],
    ClusterType: NotRequired[ClusterTypeType],  # (1)
    ClusterArn: NotRequired[str],
    ClusterName: NotRequired[str],
    CreationTime: NotRequired[datetime],
    CurrentVersion: NotRequired[str],
    State: NotRequired[ClusterStateType],  # (2)
    StateInfo: NotRequired[StateInfoTypeDef],  # (3)
    Tags: NotRequired[dict[str, str]],
    Provisioned: NotRequired[ProvisionedTypeDef],  # (4)
    Serverless: NotRequired[ServerlessTypeDef],  # (5)
  1. See ClusterTypeType
  2. See ClusterStateType
  3. See StateInfoTypeDef
  4. See ProvisionedTypeDef
  5. See ServerlessTypeDef

ProvisionedRequestTypeDef#

# ProvisionedRequestTypeDef definition

class ProvisionedRequestTypeDef(TypedDict):
    BrokerNodeGroupInfo: BrokerNodeGroupInfoUnionTypeDef,  # (1)
    KafkaVersion: str,
    NumberOfBrokerNodes: int,
    ClientAuthentication: NotRequired[ClientAuthenticationUnionTypeDef],  # (2)
    ConfigurationInfo: NotRequired[ConfigurationInfoTypeDef],  # (3)
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (4)
    EnhancedMonitoring: NotRequired[EnhancedMonitoringType],  # (5)
    OpenMonitoring: NotRequired[OpenMonitoringInfoTypeDef],  # (6)
    LoggingInfo: NotRequired[LoggingInfoTypeDef],  # (7)
    StorageMode: NotRequired[StorageModeType],  # (8)
  1. See BrokerNodeGroupInfoTypeDef BrokerNodeGroupInfoOutputTypeDef
  2. See ClientAuthenticationTypeDef ClientAuthenticationOutputTypeDef
  3. See ConfigurationInfoTypeDef
  4. See EncryptionInfoTypeDef
  5. See EnhancedMonitoringType
  6. See OpenMonitoringInfoTypeDef
  7. See LoggingInfoTypeDef
  8. See StorageModeType

DescribeClusterOperationResponseTypeDef#

# DescribeClusterOperationResponseTypeDef definition

class DescribeClusterOperationResponseTypeDef(TypedDict):
    ClusterOperationInfo: ClusterOperationInfoTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterOperationInfoTypeDef
  2. See ResponseMetadataTypeDef

ListClusterOperationsResponseTypeDef#

# ListClusterOperationsResponseTypeDef definition

class ListClusterOperationsResponseTypeDef(TypedDict):
    ClusterOperationInfoList: list[ClusterOperationInfoTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ClusterOperationInfoTypeDef
  2. See ResponseMetadataTypeDef

ClusterOperationV2TypeDef#

# ClusterOperationV2TypeDef definition

class ClusterOperationV2TypeDef(TypedDict):
    ClusterArn: NotRequired[str],
    ClusterType: NotRequired[ClusterTypeType],  # (1)
    StartTime: NotRequired[datetime],
    EndTime: NotRequired[datetime],
    ErrorInfo: NotRequired[ErrorInfoTypeDef],  # (2)
    OperationArn: NotRequired[str],
    OperationState: NotRequired[str],
    OperationType: NotRequired[str],
    Provisioned: NotRequired[ClusterOperationV2ProvisionedTypeDef],  # (3)
    Serverless: NotRequired[ClusterOperationV2ServerlessTypeDef],  # (4)
  1. See ClusterTypeType
  2. See ErrorInfoTypeDef
  3. See ClusterOperationV2ProvisionedTypeDef
  4. See ClusterOperationV2ServerlessTypeDef

DescribeClusterV2ResponseTypeDef#

# DescribeClusterV2ResponseTypeDef definition

class DescribeClusterV2ResponseTypeDef(TypedDict):
    ClusterInfo: ClusterTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterTypeDef
  2. See ResponseMetadataTypeDef

ListClustersV2ResponseTypeDef#

# ListClustersV2ResponseTypeDef definition

class ListClustersV2ResponseTypeDef(TypedDict):
    ClusterInfoList: list[ClusterTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
    NextToken: NotRequired[str],
  1. See ClusterTypeDef
  2. See ResponseMetadataTypeDef

CreateClusterV2RequestRequestTypeDef#

# CreateClusterV2RequestRequestTypeDef definition

class CreateClusterV2RequestRequestTypeDef(TypedDict):
    ClusterName: str,
    Tags: NotRequired[Mapping[str, str]],
    Provisioned: NotRequired[ProvisionedRequestTypeDef],  # (1)
    Serverless: NotRequired[ServerlessRequestTypeDef],  # (2)
  1. See ProvisionedRequestTypeDef
  2. See ServerlessRequestTypeDef

DescribeClusterOperationV2ResponseTypeDef#

# DescribeClusterOperationV2ResponseTypeDef definition

class DescribeClusterOperationV2ResponseTypeDef(TypedDict):
    ClusterOperationInfo: ClusterOperationV2TypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterOperationV2TypeDef
  2. See ResponseMetadataTypeDef