Skip to content

Type definitions#

Index > Kafka > Type definitions

Auto-generated documentation for Kafka type annotations stubs module types-aiobotocore-kafka.

BlobTypeDef#

# BlobTypeDef definition

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

BatchAssociateScramSecretRequestRequestTypeDef#

# BatchAssociateScramSecretRequestRequestTypeDef definition

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

ResponseMetadataTypeDef#

# ResponseMetadataTypeDef definition

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

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

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

TlsTypeDef#

# TlsTypeDef definition

class TlsTypeDef(TypedDict):
    CertificateAuthorityArnList: NotRequired[Sequence[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],

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,

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,

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,

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

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,

ScramTypeDef#

# ScramTypeDef definition

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

VpcConfigTypeDef#

# VpcConfigTypeDef definition

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

TagResourceRequestRequestTypeDef#

# TagResourceRequestRequestTypeDef definition

class TagResourceRequestRequestTypeDef(TypedDict):
    ResourceArn: str,
    Tags: Mapping[str, 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

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

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

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

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):
    NextToken: str,
    SecretArnList: List[str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (1)
  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

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: Union[str, bytes, IO[Any], StreamingBody],
    Description: NotRequired[str],
    KafkaVersions: NotRequired[Sequence[str]],

UpdateConfigurationRequestRequestTypeDef#

# UpdateConfigurationRequestRequestTypeDef definition

class UpdateConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,
    ServerProperties: Union[str, bytes, IO[Any], StreamingBody],
    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)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  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)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  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):
    NextToken: str,
    Revisions: List[ConfigurationRevisionTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  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

ListKafkaVersionsResponseTypeDef#

# ListKafkaVersionsResponseTypeDef definition

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

ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef#

# ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef definition

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

ListClusterOperationsRequestListClusterOperationsPaginateTypeDef#

# ListClusterOperationsRequestListClusterOperationsPaginateTypeDef definition

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

ListClusterOperationsV2RequestListClusterOperationsV2PaginateTypeDef#

# ListClusterOperationsV2RequestListClusterOperationsV2PaginateTypeDef definition

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

ListClustersRequestListClustersPaginateTypeDef#

# ListClustersRequestListClustersPaginateTypeDef definition

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

ListClustersV2RequestListClustersV2PaginateTypeDef#

# ListClustersV2RequestListClustersV2PaginateTypeDef definition

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

ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef#

# ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef definition

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

ListConfigurationsRequestListConfigurationsPaginateTypeDef#

# ListConfigurationsRequestListConfigurationsPaginateTypeDef definition

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

ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef#

# ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef definition

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

ListNodesRequestListNodesPaginateTypeDef#

# ListNodesRequestListNodesPaginateTypeDef definition

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

ListScramSecretsRequestListScramSecretsPaginateTypeDef#

# ListScramSecretsRequestListScramSecretsPaginateTypeDef definition

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

ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef#

# ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef definition

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

ListVpcConnectionsResponseTypeDef#

# ListVpcConnectionsResponseTypeDef definition

class ListVpcConnectionsResponseTypeDef(TypedDict):
    VpcConnections: List[VpcConnectionTypeDef],  # (1)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  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

SaslTypeDef#

# SaslTypeDef definition

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

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

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)
    InstanceType: NotRequired[str],
    NodeARN: NotRequired[str],
    NodeType: NotRequired[NodeTypeType],  # (2)
    ZookeeperNodeInfo: NotRequired[ZookeeperNodeInfoTypeDef],  # (3)
  1. See BrokerNodeInfoTypeDef
  2. See NodeTypeType
  3. See ZookeeperNodeInfoTypeDef

ListConfigurationsResponseTypeDef#

# ListConfigurationsResponseTypeDef definition

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

ServerlessClientAuthenticationTypeDef#

# ServerlessClientAuthenticationTypeDef definition

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

OpenMonitoringInfoTypeDef#

# OpenMonitoringInfoTypeDef definition

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

OpenMonitoringTypeDef#

# OpenMonitoringTypeDef definition

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

ClientAuthenticationTypeDef#

# ClientAuthenticationTypeDef definition

class ClientAuthenticationTypeDef(TypedDict):
    Sasl: NotRequired[SaslTypeDef],  # (1)
    Tls: NotRequired[TlsTypeDef],  # (2)
    Unauthenticated: NotRequired[UnauthenticatedTypeDef],  # (3)
  1. See SaslTypeDef
  2. See TlsTypeDef
  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

ListNodesResponseTypeDef#

# ListNodesResponseTypeDef definition

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

ServerlessRequestTypeDef#

# ServerlessRequestTypeDef definition

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

ServerlessTypeDef#

# ServerlessTypeDef definition

class ServerlessTypeDef(TypedDict):
    VpcConfigs: List[VpcConfigTypeDef],  # (1)
    ClientAuthentication: NotRequired[ServerlessClientAuthenticationTypeDef],  # (2)
  1. See VpcConfigTypeDef
  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

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

ConnectivityInfoTypeDef#

# ConnectivityInfoTypeDef definition

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

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[ClientAuthenticationTypeDef],  # (6)
    EncryptionInfo: NotRequired[EncryptionInfoTypeDef],  # (7)
    ConnectivityInfo: NotRequired[ConnectivityInfoTypeDef],  # (8)
    StorageMode: NotRequired[StorageModeType],  # (9)
  1. See BrokerEBSVolumeInfoTypeDef
  2. See ConfigurationInfoTypeDef
  3. See EnhancedMonitoringType
  4. See OpenMonitoringTypeDef
  5. See LoggingInfoTypeDef
  6. See ClientAuthenticationTypeDef
  7. See EncryptionInfoTypeDef
  8. See ConnectivityInfoTypeDef
  9. See StorageModeType

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[BrokerNodeGroupInfoTypeDef],  # (1)
    ClientAuthentication: NotRequired[ClientAuthenticationTypeDef],  # (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)
  1. See BrokerNodeGroupInfoTypeDef
  2. See ClientAuthenticationTypeDef
  3. See BrokerSoftwareInfoTypeDef
  4. See EncryptionInfoTypeDef
  5. See EnhancedMonitoringType
  6. See OpenMonitoringTypeDef
  7. See LoggingInfoTypeDef
  8. See ClusterStateType
  9. See StateInfoTypeDef
  10. See StorageModeType

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

ProvisionedRequestTypeDef#

# ProvisionedRequestTypeDef definition

class ProvisionedRequestTypeDef(TypedDict):
    BrokerNodeGroupInfo: BrokerNodeGroupInfoTypeDef,  # (1)
    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)
    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

ProvisionedTypeDef#

# ProvisionedTypeDef definition

class ProvisionedTypeDef(TypedDict):
    BrokerNodeGroupInfo: BrokerNodeGroupInfoTypeDef,  # (1)
    NumberOfBrokerNodes: int,
    CurrentBrokerSoftwareInfo: NotRequired[BrokerSoftwareInfoTypeDef],  # (2)
    ClientAuthentication: NotRequired[ClientAuthenticationTypeDef],  # (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)
  1. See BrokerNodeGroupInfoTypeDef
  2. See BrokerSoftwareInfoTypeDef
  3. See ClientAuthenticationTypeDef
  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)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterInfoTypeDef
  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

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

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)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  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)
    NextToken: str,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ClusterTypeDef
  2. See ResponseMetadataTypeDef

DescribeClusterOperationV2ResponseTypeDef#

# DescribeClusterOperationV2ResponseTypeDef definition

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