Skip to content

Typed dictionaries#

Index > Kafka > Typed dictionaries

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

BatchAssociateScramSecretRequestRequestTypeDef#

# BatchAssociateScramSecretRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import BatchAssociateScramSecretRequestRequestTypeDef

def get_value() -> BatchAssociateScramSecretRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "SecretArnList": ...,
    }
# BatchAssociateScramSecretRequestRequestTypeDef definition

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

UnprocessedScramSecretTypeDef#

# UnprocessedScramSecretTypeDef usage example

from mypy_boto3_kafka.type_defs import UnprocessedScramSecretTypeDef

def get_value() -> UnprocessedScramSecretTypeDef:
    return {
        "ErrorCode": ...,
    }
# UnprocessedScramSecretTypeDef definition

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

BatchDisassociateScramSecretRequestRequestTypeDef#

# BatchDisassociateScramSecretRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import BatchDisassociateScramSecretRequestRequestTypeDef

def get_value() -> BatchDisassociateScramSecretRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "SecretArnList": ...,
    }
# BatchDisassociateScramSecretRequestRequestTypeDef definition

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

ProvisionedThroughputTypeDef#

# ProvisionedThroughputTypeDef usage example

from mypy_boto3_kafka.type_defs import ProvisionedThroughputTypeDef

def get_value() -> ProvisionedThroughputTypeDef:
    return {
        "Enabled": ...,
    }
# ProvisionedThroughputTypeDef definition

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

CloudWatchLogsTypeDef#

# CloudWatchLogsTypeDef usage example

from mypy_boto3_kafka.type_defs import CloudWatchLogsTypeDef

def get_value() -> CloudWatchLogsTypeDef:
    return {
        "Enabled": ...,
    }
# CloudWatchLogsTypeDef definition

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

FirehoseTypeDef#

# FirehoseTypeDef usage example

from mypy_boto3_kafka.type_defs import FirehoseTypeDef

def get_value() -> FirehoseTypeDef:
    return {
        "Enabled": ...,
    }
# FirehoseTypeDef definition

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

S3TypeDef#

# S3TypeDef usage example

from mypy_boto3_kafka.type_defs import S3TypeDef

def get_value() -> S3TypeDef:
    return {
        "Enabled": ...,
    }
# S3TypeDef definition

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

BrokerSoftwareInfoTypeDef#

# BrokerSoftwareInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import BrokerSoftwareInfoTypeDef

def get_value() -> BrokerSoftwareInfoTypeDef:
    return {
        "ConfigurationArn": ...,
    }
# BrokerSoftwareInfoTypeDef definition

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

TlsTypeDef#

# TlsTypeDef usage example

from mypy_boto3_kafka.type_defs import TlsTypeDef

def get_value() -> TlsTypeDef:
    return {
        "CertificateAuthorityArnList": ...,
    }
# TlsTypeDef definition

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

UnauthenticatedTypeDef#

# UnauthenticatedTypeDef usage example

from mypy_boto3_kafka.type_defs import UnauthenticatedTypeDef

def get_value() -> UnauthenticatedTypeDef:
    return {
        "Enabled": ...,
    }
# UnauthenticatedTypeDef definition

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

ClientVpcConnectionTypeDef#

# ClientVpcConnectionTypeDef usage example

from mypy_boto3_kafka.type_defs import ClientVpcConnectionTypeDef

def get_value() -> ClientVpcConnectionTypeDef:
    return {
        "VpcConnectionArn": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import StateInfoTypeDef

def get_value() -> StateInfoTypeDef:
    return {
        "Code": ...,
    }
# StateInfoTypeDef definition

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

ErrorInfoTypeDef#

# ErrorInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import ErrorInfoTypeDef

def get_value() -> ErrorInfoTypeDef:
    return {
        "ErrorCode": ...,
    }
# ErrorInfoTypeDef definition

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

ClusterOperationStepInfoTypeDef#

# ClusterOperationStepInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import ClusterOperationStepInfoTypeDef

def get_value() -> ClusterOperationStepInfoTypeDef:
    return {
        "StepStatus": ...,
    }
# ClusterOperationStepInfoTypeDef definition

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

CompatibleKafkaVersionTypeDef#

# CompatibleKafkaVersionTypeDef usage example

from mypy_boto3_kafka.type_defs import CompatibleKafkaVersionTypeDef

def get_value() -> CompatibleKafkaVersionTypeDef:
    return {
        "SourceVersion": ...,
    }
# CompatibleKafkaVersionTypeDef definition

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

ConfigurationInfoTypeDef#

# ConfigurationInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import ConfigurationInfoTypeDef

def get_value() -> ConfigurationInfoTypeDef:
    return {
        "Arn": ...,
        "Revision": ...,
    }
# ConfigurationInfoTypeDef definition

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

ConfigurationRevisionTypeDef#

# ConfigurationRevisionTypeDef usage example

from mypy_boto3_kafka.type_defs import ConfigurationRevisionTypeDef

def get_value() -> ConfigurationRevisionTypeDef:
    return {
        "CreationTime": ...,
        "Revision": ...,
    }
# ConfigurationRevisionTypeDef definition

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

PublicAccessTypeDef#

# PublicAccessTypeDef usage example

from mypy_boto3_kafka.type_defs import PublicAccessTypeDef

def get_value() -> PublicAccessTypeDef:
    return {
        "Type": ...,
    }
# PublicAccessTypeDef definition

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

CreateClusterResponseTypeDef#

# CreateClusterResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import CreateClusterResponseTypeDef

def get_value() -> CreateClusterResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterName": ...,
        "State": ...,
        "ResponseMetadata": ...,
    }
# CreateClusterResponseTypeDef definition

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

CreateClusterV2ResponseTypeDef#

# CreateClusterV2ResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import CreateClusterV2ResponseTypeDef

def get_value() -> CreateClusterV2ResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterName": ...,
        "State": ...,
        "ClusterType": ...,
        "ResponseMetadata": ...,
    }
# 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

CreateConfigurationRequestRequestTypeDef#

# CreateConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import CreateConfigurationRequestRequestTypeDef

def get_value() -> CreateConfigurationRequestRequestTypeDef:
    return {
        "Name": ...,
        "ServerProperties": ...,
    }
# CreateConfigurationRequestRequestTypeDef definition

class CreateConfigurationRequestRequestTypeDef(TypedDict):
    Name: str,
    ServerProperties: Union[str, bytes, IO[Any], StreamingBody],
    Description: NotRequired[str],
    KafkaVersions: NotRequired[Sequence[str]],

CreateVpcConnectionRequestRequestTypeDef#

# CreateVpcConnectionRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import CreateVpcConnectionRequestRequestTypeDef

def get_value() -> CreateVpcConnectionRequestRequestTypeDef:
    return {
        "TargetClusterArn": ...,
        "Authentication": ...,
        "VpcId": ...,
        "ClientSubnets": ...,
        "SecurityGroups": ...,
    }
# CreateVpcConnectionRequestRequestTypeDef definition

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

CreateVpcConnectionResponseTypeDef#

# CreateVpcConnectionResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import CreateVpcConnectionResponseTypeDef

def get_value() -> CreateVpcConnectionResponseTypeDef:
    return {
        "VpcConnectionArn": ...,
        "State": ...,
        "Authentication": ...,
        "VpcId": ...,
        "ClientSubnets": ...,
        "SecurityGroups": ...,
        "CreationTime": ...,
        "Tags": ...,
        "ResponseMetadata": ...,
    }
# 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

DeleteClusterPolicyRequestRequestTypeDef#

# DeleteClusterPolicyRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteClusterPolicyRequestRequestTypeDef

def get_value() -> DeleteClusterPolicyRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# DeleteClusterPolicyRequestRequestTypeDef definition

class DeleteClusterPolicyRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

DeleteClusterRequestRequestTypeDef#

# DeleteClusterRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteClusterRequestRequestTypeDef

def get_value() -> DeleteClusterRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# DeleteClusterRequestRequestTypeDef definition

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

DeleteClusterResponseTypeDef#

# DeleteClusterResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteClusterResponseTypeDef

def get_value() -> DeleteClusterResponseTypeDef:
    return {
        "ClusterArn": ...,
        "State": ...,
        "ResponseMetadata": ...,
    }
# DeleteClusterResponseTypeDef definition

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

DeleteConfigurationRequestRequestTypeDef#

# DeleteConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteConfigurationRequestRequestTypeDef

def get_value() -> DeleteConfigurationRequestRequestTypeDef:
    return {
        "Arn": ...,
    }
# DeleteConfigurationRequestRequestTypeDef definition

class DeleteConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,

DeleteConfigurationResponseTypeDef#

# DeleteConfigurationResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteConfigurationResponseTypeDef

def get_value() -> DeleteConfigurationResponseTypeDef:
    return {
        "Arn": ...,
        "State": ...,
        "ResponseMetadata": ...,
    }
# DeleteConfigurationResponseTypeDef definition

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

DeleteVpcConnectionRequestRequestTypeDef#

# DeleteVpcConnectionRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteVpcConnectionRequestRequestTypeDef

def get_value() -> DeleteVpcConnectionRequestRequestTypeDef:
    return {
        "Arn": ...,
    }
# DeleteVpcConnectionRequestRequestTypeDef definition

class DeleteVpcConnectionRequestRequestTypeDef(TypedDict):
    Arn: str,

DeleteVpcConnectionResponseTypeDef#

# DeleteVpcConnectionResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DeleteVpcConnectionResponseTypeDef

def get_value() -> DeleteVpcConnectionResponseTypeDef:
    return {
        "VpcConnectionArn": ...,
        "State": ...,
        "ResponseMetadata": ...,
    }
# DeleteVpcConnectionResponseTypeDef definition

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

DescribeClusterOperationRequestRequestTypeDef#

# DescribeClusterOperationRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeClusterOperationRequestRequestTypeDef

def get_value() -> DescribeClusterOperationRequestRequestTypeDef:
    return {
        "ClusterOperationArn": ...,
    }
# DescribeClusterOperationRequestRequestTypeDef definition

class DescribeClusterOperationRequestRequestTypeDef(TypedDict):
    ClusterOperationArn: str,

DescribeClusterRequestRequestTypeDef#

# DescribeClusterRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeClusterRequestRequestTypeDef

def get_value() -> DescribeClusterRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# DescribeClusterRequestRequestTypeDef definition

class DescribeClusterRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

DescribeClusterV2RequestRequestTypeDef#

# DescribeClusterV2RequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeClusterV2RequestRequestTypeDef

def get_value() -> DescribeClusterV2RequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# DescribeClusterV2RequestRequestTypeDef definition

class DescribeClusterV2RequestRequestTypeDef(TypedDict):
    ClusterArn: str,

DescribeConfigurationRequestRequestTypeDef#

# DescribeConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeConfigurationRequestRequestTypeDef

def get_value() -> DescribeConfigurationRequestRequestTypeDef:
    return {
        "Arn": ...,
    }
# DescribeConfigurationRequestRequestTypeDef definition

class DescribeConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,

DescribeConfigurationRevisionRequestRequestTypeDef#

# DescribeConfigurationRevisionRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeConfigurationRevisionRequestRequestTypeDef

def get_value() -> DescribeConfigurationRevisionRequestRequestTypeDef:
    return {
        "Arn": ...,
        "Revision": ...,
    }
# DescribeConfigurationRevisionRequestRequestTypeDef definition

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

DescribeConfigurationRevisionResponseTypeDef#

# DescribeConfigurationRevisionResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeConfigurationRevisionResponseTypeDef

def get_value() -> DescribeConfigurationRevisionResponseTypeDef:
    return {
        "Arn": ...,
        "CreationTime": ...,
        "Description": ...,
        "Revision": ...,
        "ServerProperties": ...,
        "ResponseMetadata": ...,
    }
# DescribeConfigurationRevisionResponseTypeDef definition

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

DescribeVpcConnectionRequestRequestTypeDef#

# DescribeVpcConnectionRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeVpcConnectionRequestRequestTypeDef

def get_value() -> DescribeVpcConnectionRequestRequestTypeDef:
    return {
        "Arn": ...,
    }
# DescribeVpcConnectionRequestRequestTypeDef definition

class DescribeVpcConnectionRequestRequestTypeDef(TypedDict):
    Arn: str,

DescribeVpcConnectionResponseTypeDef#

# DescribeVpcConnectionResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeVpcConnectionResponseTypeDef

def get_value() -> DescribeVpcConnectionResponseTypeDef:
    return {
        "VpcConnectionArn": ...,
        "TargetClusterArn": ...,
        "State": ...,
        "Authentication": ...,
        "VpcId": ...,
        "Subnets": ...,
        "SecurityGroups": ...,
        "CreationTime": ...,
        "Tags": ...,
        "ResponseMetadata": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import EmptyResponseMetadataTypeDef

def get_value() -> EmptyResponseMetadataTypeDef:
    return {
        "ResponseMetadata": ...,
    }
# EmptyResponseMetadataTypeDef definition

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

EncryptionAtRestTypeDef#

# EncryptionAtRestTypeDef usage example

from mypy_boto3_kafka.type_defs import EncryptionAtRestTypeDef

def get_value() -> EncryptionAtRestTypeDef:
    return {
        "DataVolumeKMSKeyId": ...,
    }
# EncryptionAtRestTypeDef definition

class EncryptionAtRestTypeDef(TypedDict):
    DataVolumeKMSKeyId: str,

EncryptionInTransitTypeDef#

# EncryptionInTransitTypeDef usage example

from mypy_boto3_kafka.type_defs import EncryptionInTransitTypeDef

def get_value() -> EncryptionInTransitTypeDef:
    return {
        "ClientBroker": ...,
    }
# EncryptionInTransitTypeDef definition

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

GetBootstrapBrokersRequestRequestTypeDef#

# GetBootstrapBrokersRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import GetBootstrapBrokersRequestRequestTypeDef

def get_value() -> GetBootstrapBrokersRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# GetBootstrapBrokersRequestRequestTypeDef definition

class GetBootstrapBrokersRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

GetBootstrapBrokersResponseTypeDef#

# GetBootstrapBrokersResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import GetBootstrapBrokersResponseTypeDef

def get_value() -> GetBootstrapBrokersResponseTypeDef:
    return {
        "BootstrapBrokerString": ...,
        "BootstrapBrokerStringTls": ...,
        "BootstrapBrokerStringSaslScram": ...,
        "BootstrapBrokerStringSaslIam": ...,
        "BootstrapBrokerStringPublicTls": ...,
        "BootstrapBrokerStringPublicSaslScram": ...,
        "BootstrapBrokerStringPublicSaslIam": ...,
        "BootstrapBrokerStringVpcConnectivityTls": ...,
        "BootstrapBrokerStringVpcConnectivitySaslScram": ...,
        "BootstrapBrokerStringVpcConnectivitySaslIam": ...,
        "ResponseMetadata": ...,
    }
# 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

GetClusterPolicyRequestRequestTypeDef#

# GetClusterPolicyRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import GetClusterPolicyRequestRequestTypeDef

def get_value() -> GetClusterPolicyRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# GetClusterPolicyRequestRequestTypeDef definition

class GetClusterPolicyRequestRequestTypeDef(TypedDict):
    ClusterArn: str,

GetClusterPolicyResponseTypeDef#

# GetClusterPolicyResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import GetClusterPolicyResponseTypeDef

def get_value() -> GetClusterPolicyResponseTypeDef:
    return {
        "CurrentVersion": ...,
        "Policy": ...,
        "ResponseMetadata": ...,
    }
# GetClusterPolicyResponseTypeDef definition

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

GetCompatibleKafkaVersionsRequestRequestTypeDef#

# GetCompatibleKafkaVersionsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import GetCompatibleKafkaVersionsRequestRequestTypeDef

def get_value() -> GetCompatibleKafkaVersionsRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# GetCompatibleKafkaVersionsRequestRequestTypeDef definition

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

IamTypeDef#

# IamTypeDef usage example

from mypy_boto3_kafka.type_defs import IamTypeDef

def get_value() -> IamTypeDef:
    return {
        "Enabled": ...,
    }
# IamTypeDef definition

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

JmxExporterInfoTypeDef#

# JmxExporterInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import JmxExporterInfoTypeDef

def get_value() -> JmxExporterInfoTypeDef:
    return {
        "EnabledInBroker": ...,
    }
# JmxExporterInfoTypeDef definition

class JmxExporterInfoTypeDef(TypedDict):
    EnabledInBroker: bool,

JmxExporterTypeDef#

# JmxExporterTypeDef usage example

from mypy_boto3_kafka.type_defs import JmxExporterTypeDef

def get_value() -> JmxExporterTypeDef:
    return {
        "EnabledInBroker": ...,
    }
# JmxExporterTypeDef definition

class JmxExporterTypeDef(TypedDict):
    EnabledInBroker: bool,

KafkaVersionTypeDef#

# KafkaVersionTypeDef usage example

from mypy_boto3_kafka.type_defs import KafkaVersionTypeDef

def get_value() -> KafkaVersionTypeDef:
    return {
        "Version": ...,
    }
# KafkaVersionTypeDef definition

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

ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef#

# ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef

def get_value() -> ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListClientVpcConnectionsRequestListClientVpcConnectionsPaginateTypeDef definition

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

ListClientVpcConnectionsRequestRequestTypeDef#

# ListClientVpcConnectionsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClientVpcConnectionsRequestRequestTypeDef

def get_value() -> ListClientVpcConnectionsRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListClientVpcConnectionsRequestRequestTypeDef definition

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

ListClusterOperationsRequestListClusterOperationsPaginateTypeDef#

# ListClusterOperationsRequestListClusterOperationsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClusterOperationsRequestListClusterOperationsPaginateTypeDef

def get_value() -> ListClusterOperationsRequestListClusterOperationsPaginateTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListClusterOperationsRequestListClusterOperationsPaginateTypeDef definition

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

ListClusterOperationsRequestRequestTypeDef#

# ListClusterOperationsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClusterOperationsRequestRequestTypeDef

def get_value() -> ListClusterOperationsRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListClusterOperationsRequestRequestTypeDef definition

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

ListClustersRequestListClustersPaginateTypeDef#

# ListClustersRequestListClustersPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClustersRequestListClustersPaginateTypeDef

def get_value() -> ListClustersRequestListClustersPaginateTypeDef:
    return {
        "ClusterNameFilter": ...,
    }
# ListClustersRequestListClustersPaginateTypeDef definition

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

ListClustersRequestRequestTypeDef#

# ListClustersRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClustersRequestRequestTypeDef

def get_value() -> ListClustersRequestRequestTypeDef:
    return {
        "ClusterNameFilter": ...,
    }
# ListClustersRequestRequestTypeDef definition

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

ListClustersV2RequestListClustersV2PaginateTypeDef#

# ListClustersV2RequestListClustersV2PaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClustersV2RequestListClustersV2PaginateTypeDef

def get_value() -> ListClustersV2RequestListClustersV2PaginateTypeDef:
    return {
        "ClusterNameFilter": ...,
    }
# ListClustersV2RequestListClustersV2PaginateTypeDef definition

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

ListClustersV2RequestRequestTypeDef#

# ListClustersV2RequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClustersV2RequestRequestTypeDef

def get_value() -> ListClustersV2RequestRequestTypeDef:
    return {
        "ClusterNameFilter": ...,
    }
# ListClustersV2RequestRequestTypeDef definition

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

ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef#

# ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef

def get_value() -> ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef:
    return {
        "Arn": ...,
    }
# ListConfigurationRevisionsRequestListConfigurationRevisionsPaginateTypeDef definition

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

ListConfigurationRevisionsRequestRequestTypeDef#

# ListConfigurationRevisionsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListConfigurationRevisionsRequestRequestTypeDef

def get_value() -> ListConfigurationRevisionsRequestRequestTypeDef:
    return {
        "Arn": ...,
    }
# ListConfigurationRevisionsRequestRequestTypeDef definition

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

ListConfigurationsRequestListConfigurationsPaginateTypeDef#

# ListConfigurationsRequestListConfigurationsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListConfigurationsRequestListConfigurationsPaginateTypeDef

def get_value() -> ListConfigurationsRequestListConfigurationsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
# ListConfigurationsRequestListConfigurationsPaginateTypeDef definition

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

ListConfigurationsRequestRequestTypeDef#

# ListConfigurationsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListConfigurationsRequestRequestTypeDef

def get_value() -> ListConfigurationsRequestRequestTypeDef:
    return {
        "MaxResults": ...,
    }
# ListConfigurationsRequestRequestTypeDef definition

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

ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef#

# ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef

def get_value() -> ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
# ListKafkaVersionsRequestListKafkaVersionsPaginateTypeDef definition

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

ListKafkaVersionsRequestRequestTypeDef#

# ListKafkaVersionsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListKafkaVersionsRequestRequestTypeDef

def get_value() -> ListKafkaVersionsRequestRequestTypeDef:
    return {
        "MaxResults": ...,
    }
# ListKafkaVersionsRequestRequestTypeDef definition

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

ListNodesRequestListNodesPaginateTypeDef#

# ListNodesRequestListNodesPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListNodesRequestListNodesPaginateTypeDef

def get_value() -> ListNodesRequestListNodesPaginateTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListNodesRequestListNodesPaginateTypeDef definition

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

ListNodesRequestRequestTypeDef#

# ListNodesRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListNodesRequestRequestTypeDef

def get_value() -> ListNodesRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListNodesRequestRequestTypeDef definition

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

ListScramSecretsRequestListScramSecretsPaginateTypeDef#

# ListScramSecretsRequestListScramSecretsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListScramSecretsRequestListScramSecretsPaginateTypeDef

def get_value() -> ListScramSecretsRequestListScramSecretsPaginateTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListScramSecretsRequestListScramSecretsPaginateTypeDef definition

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

ListScramSecretsRequestRequestTypeDef#

# ListScramSecretsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListScramSecretsRequestRequestTypeDef

def get_value() -> ListScramSecretsRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
    }
# ListScramSecretsRequestRequestTypeDef definition

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

ListScramSecretsResponseTypeDef#

# ListScramSecretsResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListScramSecretsResponseTypeDef

def get_value() -> ListScramSecretsResponseTypeDef:
    return {
        "NextToken": ...,
        "SecretArnList": ...,
        "ResponseMetadata": ...,
    }
# ListScramSecretsResponseTypeDef definition

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

ListTagsForResourceRequestRequestTypeDef#

# ListTagsForResourceRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListTagsForResourceRequestRequestTypeDef

def get_value() -> ListTagsForResourceRequestRequestTypeDef:
    return {
        "ResourceArn": ...,
    }
# ListTagsForResourceRequestRequestTypeDef definition

class ListTagsForResourceRequestRequestTypeDef(TypedDict):
    ResourceArn: str,

ListTagsForResourceResponseTypeDef#

# ListTagsForResourceResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListTagsForResourceResponseTypeDef

def get_value() -> ListTagsForResourceResponseTypeDef:
    return {
        "Tags": ...,
        "ResponseMetadata": ...,
    }
# ListTagsForResourceResponseTypeDef definition

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

ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef#

# ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef usage example

from mypy_boto3_kafka.type_defs import ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef

def get_value() -> ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef:
    return {
        "PaginationConfig": ...,
    }
# ListVpcConnectionsRequestListVpcConnectionsPaginateTypeDef definition

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

ListVpcConnectionsRequestRequestTypeDef#

# ListVpcConnectionsRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ListVpcConnectionsRequestRequestTypeDef

def get_value() -> ListVpcConnectionsRequestRequestTypeDef:
    return {
        "MaxResults": ...,
    }
# ListVpcConnectionsRequestRequestTypeDef definition

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

VpcConnectionTypeDef#

# VpcConnectionTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectionTypeDef

def get_value() -> VpcConnectionTypeDef:
    return {
        "VpcConnectionArn": ...,
        "TargetClusterArn": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import NodeExporterInfoTypeDef

def get_value() -> NodeExporterInfoTypeDef:
    return {
        "EnabledInBroker": ...,
    }
# NodeExporterInfoTypeDef definition

class NodeExporterInfoTypeDef(TypedDict):
    EnabledInBroker: bool,

NodeExporterTypeDef#

# NodeExporterTypeDef usage example

from mypy_boto3_kafka.type_defs import NodeExporterTypeDef

def get_value() -> NodeExporterTypeDef:
    return {
        "EnabledInBroker": ...,
    }
# NodeExporterTypeDef definition

class NodeExporterTypeDef(TypedDict):
    EnabledInBroker: bool,

ZookeeperNodeInfoTypeDef#

# ZookeeperNodeInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import ZookeeperNodeInfoTypeDef

def get_value() -> ZookeeperNodeInfoTypeDef:
    return {
        "AttachedENIId": ...,
    }
# ZookeeperNodeInfoTypeDef definition

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

PaginatorConfigTypeDef#

# PaginatorConfigTypeDef usage example

from mypy_boto3_kafka.type_defs import PaginatorConfigTypeDef

def get_value() -> PaginatorConfigTypeDef:
    return {
        "MaxItems": ...,
    }
# PaginatorConfigTypeDef definition

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

PutClusterPolicyRequestRequestTypeDef#

# PutClusterPolicyRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import PutClusterPolicyRequestRequestTypeDef

def get_value() -> PutClusterPolicyRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "Policy": ...,
    }
# PutClusterPolicyRequestRequestTypeDef definition

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

PutClusterPolicyResponseTypeDef#

# PutClusterPolicyResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import PutClusterPolicyResponseTypeDef

def get_value() -> PutClusterPolicyResponseTypeDef:
    return {
        "CurrentVersion": ...,
        "ResponseMetadata": ...,
    }
# PutClusterPolicyResponseTypeDef definition

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

RebootBrokerRequestRequestTypeDef#

# RebootBrokerRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import RebootBrokerRequestRequestTypeDef

def get_value() -> RebootBrokerRequestRequestTypeDef:
    return {
        "BrokerIds": ...,
        "ClusterArn": ...,
    }
# RebootBrokerRequestRequestTypeDef definition

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

RebootBrokerResponseTypeDef#

# RebootBrokerResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import RebootBrokerResponseTypeDef

def get_value() -> RebootBrokerResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# RebootBrokerResponseTypeDef definition

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

RejectClientVpcConnectionRequestRequestTypeDef#

# RejectClientVpcConnectionRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import RejectClientVpcConnectionRequestRequestTypeDef

def get_value() -> RejectClientVpcConnectionRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "VpcConnectionArn": ...,
    }
# RejectClientVpcConnectionRequestRequestTypeDef definition

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

ResponseMetadataTypeDef#

# ResponseMetadataTypeDef usage example

from mypy_boto3_kafka.type_defs import ResponseMetadataTypeDef

def get_value() -> ResponseMetadataTypeDef:
    return {
        "RequestId": ...,
        "HostId": ...,
        "HTTPStatusCode": ...,
        "HTTPHeaders": ...,
        "RetryAttempts": ...,
    }
# ResponseMetadataTypeDef definition

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

ScramTypeDef#

# ScramTypeDef usage example

from mypy_boto3_kafka.type_defs import ScramTypeDef

def get_value() -> ScramTypeDef:
    return {
        "Enabled": ...,
    }
# ScramTypeDef definition

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

VpcConfigTypeDef#

# VpcConfigTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConfigTypeDef

def get_value() -> VpcConfigTypeDef:
    return {
        "SubnetIds": ...,
    }
# VpcConfigTypeDef definition

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

TagResourceRequestRequestTypeDef#

# TagResourceRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import TagResourceRequestRequestTypeDef

def get_value() -> TagResourceRequestRequestTypeDef:
    return {
        "ResourceArn": ...,
        "Tags": ...,
    }
# TagResourceRequestRequestTypeDef definition

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

UntagResourceRequestRequestTypeDef#

# UntagResourceRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UntagResourceRequestRequestTypeDef

def get_value() -> UntagResourceRequestRequestTypeDef:
    return {
        "ResourceArn": ...,
        "TagKeys": ...,
    }
# UntagResourceRequestRequestTypeDef definition

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

UpdateBrokerCountRequestRequestTypeDef#

# UpdateBrokerCountRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateBrokerCountRequestRequestTypeDef

def get_value() -> UpdateBrokerCountRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
        "TargetNumberOfBrokerNodes": ...,
    }
# UpdateBrokerCountRequestRequestTypeDef definition

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

UpdateBrokerCountResponseTypeDef#

# UpdateBrokerCountResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateBrokerCountResponseTypeDef

def get_value() -> UpdateBrokerCountResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateBrokerCountResponseTypeDef definition

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

UpdateBrokerStorageResponseTypeDef#

# UpdateBrokerStorageResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateBrokerStorageResponseTypeDef

def get_value() -> UpdateBrokerStorageResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateBrokerStorageResponseTypeDef definition

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

UpdateBrokerTypeRequestRequestTypeDef#

# UpdateBrokerTypeRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateBrokerTypeRequestRequestTypeDef

def get_value() -> UpdateBrokerTypeRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
        "TargetInstanceType": ...,
    }
# UpdateBrokerTypeRequestRequestTypeDef definition

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

UpdateBrokerTypeResponseTypeDef#

# UpdateBrokerTypeResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateBrokerTypeResponseTypeDef

def get_value() -> UpdateBrokerTypeResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateBrokerTypeResponseTypeDef definition

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

UpdateClusterConfigurationResponseTypeDef#

# UpdateClusterConfigurationResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateClusterConfigurationResponseTypeDef

def get_value() -> UpdateClusterConfigurationResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateClusterConfigurationResponseTypeDef definition

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

UpdateClusterKafkaVersionResponseTypeDef#

# UpdateClusterKafkaVersionResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateClusterKafkaVersionResponseTypeDef

def get_value() -> UpdateClusterKafkaVersionResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateClusterKafkaVersionResponseTypeDef definition

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

UpdateConfigurationRequestRequestTypeDef#

# UpdateConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateConfigurationRequestRequestTypeDef

def get_value() -> UpdateConfigurationRequestRequestTypeDef:
    return {
        "Arn": ...,
        "ServerProperties": ...,
    }
# UpdateConfigurationRequestRequestTypeDef definition

class UpdateConfigurationRequestRequestTypeDef(TypedDict):
    Arn: str,
    ServerProperties: Union[str, bytes, IO[Any], StreamingBody],
    Description: NotRequired[str],

UpdateConnectivityResponseTypeDef#

# UpdateConnectivityResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateConnectivityResponseTypeDef

def get_value() -> UpdateConnectivityResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateConnectivityResponseTypeDef definition

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

UpdateMonitoringResponseTypeDef#

# UpdateMonitoringResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateMonitoringResponseTypeDef

def get_value() -> UpdateMonitoringResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateMonitoringResponseTypeDef definition

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

UpdateSecurityResponseTypeDef#

# UpdateSecurityResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateSecurityResponseTypeDef

def get_value() -> UpdateSecurityResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateSecurityResponseTypeDef definition

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

UpdateStorageResponseTypeDef#

# UpdateStorageResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateStorageResponseTypeDef

def get_value() -> UpdateStorageResponseTypeDef:
    return {
        "ClusterArn": ...,
        "ClusterOperationArn": ...,
        "ResponseMetadata": ...,
    }
# UpdateStorageResponseTypeDef definition

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

UserIdentityTypeDef#

# UserIdentityTypeDef usage example

from mypy_boto3_kafka.type_defs import UserIdentityTypeDef

def get_value() -> UserIdentityTypeDef:
    return {
        "Type": ...,
    }
# UserIdentityTypeDef definition

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

VpcConnectivityTlsTypeDef#

# VpcConnectivityTlsTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectivityTlsTypeDef

def get_value() -> VpcConnectivityTlsTypeDef:
    return {
        "Enabled": ...,
    }
# VpcConnectivityTlsTypeDef definition

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

VpcConnectivityIamTypeDef#

# VpcConnectivityIamTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectivityIamTypeDef

def get_value() -> VpcConnectivityIamTypeDef:
    return {
        "Enabled": ...,
    }
# VpcConnectivityIamTypeDef definition

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

VpcConnectivityScramTypeDef#

# VpcConnectivityScramTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectivityScramTypeDef

def get_value() -> VpcConnectivityScramTypeDef:
    return {
        "Enabled": ...,
    }
# VpcConnectivityScramTypeDef definition

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

BatchAssociateScramSecretResponseTypeDef#

# BatchAssociateScramSecretResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import BatchAssociateScramSecretResponseTypeDef

def get_value() -> BatchAssociateScramSecretResponseTypeDef:
    return {
        "ClusterArn": ...,
        "UnprocessedScramSecrets": ...,
        "ResponseMetadata": ...,
    }
# BatchAssociateScramSecretResponseTypeDef definition

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

BatchDisassociateScramSecretResponseTypeDef#

# BatchDisassociateScramSecretResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import BatchDisassociateScramSecretResponseTypeDef

def get_value() -> BatchDisassociateScramSecretResponseTypeDef:
    return {
        "ClusterArn": ...,
        "UnprocessedScramSecrets": ...,
        "ResponseMetadata": ...,
    }
# BatchDisassociateScramSecretResponseTypeDef definition

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

BrokerEBSVolumeInfoTypeDef#

# BrokerEBSVolumeInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import BrokerEBSVolumeInfoTypeDef

def get_value() -> BrokerEBSVolumeInfoTypeDef:
    return {
        "KafkaBrokerNodeId": ...,
    }
# BrokerEBSVolumeInfoTypeDef definition

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

EBSStorageInfoTypeDef#

# EBSStorageInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import EBSStorageInfoTypeDef

def get_value() -> EBSStorageInfoTypeDef:
    return {
        "ProvisionedThroughput": ...,
    }
# EBSStorageInfoTypeDef definition

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

UpdateStorageRequestRequestTypeDef#

# UpdateStorageRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateStorageRequestRequestTypeDef

def get_value() -> UpdateStorageRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import BrokerLogsTypeDef

def get_value() -> BrokerLogsTypeDef:
    return {
        "CloudWatchLogs": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import BrokerNodeInfoTypeDef

def get_value() -> BrokerNodeInfoTypeDef:
    return {
        "AttachedENIId": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ListClientVpcConnectionsResponseTypeDef

def get_value() -> ListClientVpcConnectionsResponseTypeDef:
    return {
        "ClientVpcConnections": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListClientVpcConnectionsResponseTypeDef definition

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

ClusterOperationStepTypeDef#

# ClusterOperationStepTypeDef usage example

from mypy_boto3_kafka.type_defs import ClusterOperationStepTypeDef

def get_value() -> ClusterOperationStepTypeDef:
    return {
        "StepInfo": ...,
    }
# ClusterOperationStepTypeDef definition

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

GetCompatibleKafkaVersionsResponseTypeDef#

# GetCompatibleKafkaVersionsResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import GetCompatibleKafkaVersionsResponseTypeDef

def get_value() -> GetCompatibleKafkaVersionsResponseTypeDef:
    return {
        "CompatibleKafkaVersions": ...,
        "ResponseMetadata": ...,
    }
# GetCompatibleKafkaVersionsResponseTypeDef definition

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

UpdateClusterConfigurationRequestRequestTypeDef#

# UpdateClusterConfigurationRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateClusterConfigurationRequestRequestTypeDef

def get_value() -> UpdateClusterConfigurationRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "ConfigurationInfo": ...,
        "CurrentVersion": ...,
    }
# UpdateClusterConfigurationRequestRequestTypeDef definition

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

UpdateClusterKafkaVersionRequestRequestTypeDef#

# UpdateClusterKafkaVersionRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateClusterKafkaVersionRequestRequestTypeDef

def get_value() -> UpdateClusterKafkaVersionRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
        "TargetKafkaVersion": ...,
    }
# UpdateClusterKafkaVersionRequestRequestTypeDef definition

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

ConfigurationTypeDef#

# ConfigurationTypeDef usage example

from mypy_boto3_kafka.type_defs import ConfigurationTypeDef

def get_value() -> ConfigurationTypeDef:
    return {
        "Arn": ...,
        "CreationTime": ...,
        "Description": ...,
        "KafkaVersions": ...,
        "LatestRevision": ...,
        "Name": ...,
        "State": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import CreateConfigurationResponseTypeDef

def get_value() -> CreateConfigurationResponseTypeDef:
    return {
        "Arn": ...,
        "CreationTime": ...,
        "LatestRevision": ...,
        "Name": ...,
        "State": ...,
        "ResponseMetadata": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import DescribeConfigurationResponseTypeDef

def get_value() -> DescribeConfigurationResponseTypeDef:
    return {
        "Arn": ...,
        "CreationTime": ...,
        "Description": ...,
        "KafkaVersions": ...,
        "LatestRevision": ...,
        "Name": ...,
        "State": ...,
        "ResponseMetadata": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ListConfigurationRevisionsResponseTypeDef

def get_value() -> ListConfigurationRevisionsResponseTypeDef:
    return {
        "NextToken": ...,
        "Revisions": ...,
        "ResponseMetadata": ...,
    }
# ListConfigurationRevisionsResponseTypeDef definition

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

UpdateConfigurationResponseTypeDef#

# UpdateConfigurationResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateConfigurationResponseTypeDef

def get_value() -> UpdateConfigurationResponseTypeDef:
    return {
        "Arn": ...,
        "LatestRevision": ...,
        "ResponseMetadata": ...,
    }
# UpdateConfigurationResponseTypeDef definition

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

EncryptionInfoTypeDef#

# EncryptionInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import EncryptionInfoTypeDef

def get_value() -> EncryptionInfoTypeDef:
    return {
        "EncryptionAtRest": ...,
    }
# EncryptionInfoTypeDef definition

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

ServerlessSaslTypeDef#

# ServerlessSaslTypeDef usage example

from mypy_boto3_kafka.type_defs import ServerlessSaslTypeDef

def get_value() -> ServerlessSaslTypeDef:
    return {
        "Iam": ...,
    }
# ServerlessSaslTypeDef definition

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

ListKafkaVersionsResponseTypeDef#

# ListKafkaVersionsResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListKafkaVersionsResponseTypeDef

def get_value() -> ListKafkaVersionsResponseTypeDef:
    return {
        "KafkaVersions": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListKafkaVersionsResponseTypeDef definition

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

ListVpcConnectionsResponseTypeDef#

# ListVpcConnectionsResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListVpcConnectionsResponseTypeDef

def get_value() -> ListVpcConnectionsResponseTypeDef:
    return {
        "VpcConnections": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListVpcConnectionsResponseTypeDef definition

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

PrometheusInfoTypeDef#

# PrometheusInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import PrometheusInfoTypeDef

def get_value() -> PrometheusInfoTypeDef:
    return {
        "JmxExporter": ...,
    }
# PrometheusInfoTypeDef definition

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

PrometheusTypeDef#

# PrometheusTypeDef usage example

from mypy_boto3_kafka.type_defs import PrometheusTypeDef

def get_value() -> PrometheusTypeDef:
    return {
        "JmxExporter": ...,
    }
# PrometheusTypeDef definition

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

SaslTypeDef#

# SaslTypeDef usage example

from mypy_boto3_kafka.type_defs import SaslTypeDef

def get_value() -> SaslTypeDef:
    return {
        "Scram": ...,
    }
# SaslTypeDef definition

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

VpcConnectionInfoTypeDef#

# VpcConnectionInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectionInfoTypeDef

def get_value() -> VpcConnectionInfoTypeDef:
    return {
        "VpcConnectionArn": ...,
    }
# VpcConnectionInfoTypeDef definition

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

VpcConnectivitySaslTypeDef#

# VpcConnectivitySaslTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectivitySaslTypeDef

def get_value() -> VpcConnectivitySaslTypeDef:
    return {
        "Scram": ...,
    }
# VpcConnectivitySaslTypeDef definition

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

UpdateBrokerStorageRequestRequestTypeDef#

# UpdateBrokerStorageRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateBrokerStorageRequestRequestTypeDef

def get_value() -> UpdateBrokerStorageRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
        "TargetBrokerEBSVolumeInfo": ...,
    }
# UpdateBrokerStorageRequestRequestTypeDef definition

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

StorageInfoTypeDef#

# StorageInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import StorageInfoTypeDef

def get_value() -> StorageInfoTypeDef:
    return {
        "EbsStorageInfo": ...,
    }
# StorageInfoTypeDef definition

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

LoggingInfoTypeDef#

# LoggingInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import LoggingInfoTypeDef

def get_value() -> LoggingInfoTypeDef:
    return {
        "BrokerLogs": ...,
    }
# LoggingInfoTypeDef definition

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

NodeInfoTypeDef#

# NodeInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import NodeInfoTypeDef

def get_value() -> NodeInfoTypeDef:
    return {
        "AddedToClusterTime": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ListConfigurationsResponseTypeDef

def get_value() -> ListConfigurationsResponseTypeDef:
    return {
        "Configurations": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListConfigurationsResponseTypeDef definition

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

ServerlessClientAuthenticationTypeDef#

# ServerlessClientAuthenticationTypeDef usage example

from mypy_boto3_kafka.type_defs import ServerlessClientAuthenticationTypeDef

def get_value() -> ServerlessClientAuthenticationTypeDef:
    return {
        "Sasl": ...,
    }
# ServerlessClientAuthenticationTypeDef definition

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

OpenMonitoringInfoTypeDef#

# OpenMonitoringInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import OpenMonitoringInfoTypeDef

def get_value() -> OpenMonitoringInfoTypeDef:
    return {
        "Prometheus": ...,
    }
# OpenMonitoringInfoTypeDef definition

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

OpenMonitoringTypeDef#

# OpenMonitoringTypeDef usage example

from mypy_boto3_kafka.type_defs import OpenMonitoringTypeDef

def get_value() -> OpenMonitoringTypeDef:
    return {
        "Prometheus": ...,
    }
# OpenMonitoringTypeDef definition

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

ClientAuthenticationTypeDef#

# ClientAuthenticationTypeDef usage example

from mypy_boto3_kafka.type_defs import ClientAuthenticationTypeDef

def get_value() -> ClientAuthenticationTypeDef:
    return {
        "Sasl": ...,
    }
# 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

VpcConnectivityClientAuthenticationTypeDef#

# VpcConnectivityClientAuthenticationTypeDef usage example

from mypy_boto3_kafka.type_defs import VpcConnectivityClientAuthenticationTypeDef

def get_value() -> VpcConnectivityClientAuthenticationTypeDef:
    return {
        "Sasl": ...,
    }
# VpcConnectivityClientAuthenticationTypeDef definition

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

ListNodesResponseTypeDef#

# ListNodesResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListNodesResponseTypeDef

def get_value() -> ListNodesResponseTypeDef:
    return {
        "NextToken": ...,
        "NodeInfoList": ...,
        "ResponseMetadata": ...,
    }
# ListNodesResponseTypeDef definition

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

ServerlessRequestTypeDef#

# ServerlessRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import ServerlessRequestTypeDef

def get_value() -> ServerlessRequestTypeDef:
    return {
        "VpcConfigs": ...,
    }
# ServerlessRequestTypeDef definition

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

ServerlessTypeDef#

# ServerlessTypeDef usage example

from mypy_boto3_kafka.type_defs import ServerlessTypeDef

def get_value() -> ServerlessTypeDef:
    return {
        "VpcConfigs": ...,
    }
# ServerlessTypeDef definition

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

UpdateMonitoringRequestRequestTypeDef#

# UpdateMonitoringRequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import UpdateMonitoringRequestRequestTypeDef

def get_value() -> UpdateMonitoringRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import UpdateSecurityRequestRequestTypeDef

def get_value() -> UpdateSecurityRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "CurrentVersion": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import VpcConnectivityTypeDef

def get_value() -> VpcConnectivityTypeDef:
    return {
        "ClientAuthentication": ...,
    }
# VpcConnectivityTypeDef definition

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

ConnectivityInfoTypeDef#

# ConnectivityInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import ConnectivityInfoTypeDef

def get_value() -> ConnectivityInfoTypeDef:
    return {
        "PublicAccess": ...,
    }
# ConnectivityInfoTypeDef definition

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

BrokerNodeGroupInfoTypeDef#

# BrokerNodeGroupInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import BrokerNodeGroupInfoTypeDef

def get_value() -> BrokerNodeGroupInfoTypeDef:
    return {
        "ClientSubnets": ...,
        "InstanceType": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import MutableClusterInfoTypeDef

def get_value() -> MutableClusterInfoTypeDef:
    return {
        "BrokerEBSVolumeInfo": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import UpdateConnectivityRequestRequestTypeDef

def get_value() -> UpdateConnectivityRequestRequestTypeDef:
    return {
        "ClusterArn": ...,
        "ConnectivityInfo": ...,
        "CurrentVersion": ...,
    }
# UpdateConnectivityRequestRequestTypeDef definition

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

ClusterInfoTypeDef#

# ClusterInfoTypeDef usage example

from mypy_boto3_kafka.type_defs import ClusterInfoTypeDef

def get_value() -> ClusterInfoTypeDef:
    return {
        "ActiveOperationArn": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import CreateClusterRequestRequestTypeDef

def get_value() -> CreateClusterRequestRequestTypeDef:
    return {
        "BrokerNodeGroupInfo": ...,
        "ClusterName": ...,
        "KafkaVersion": ...,
        "NumberOfBrokerNodes": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ProvisionedRequestTypeDef

def get_value() -> ProvisionedRequestTypeDef:
    return {
        "BrokerNodeGroupInfo": ...,
        "KafkaVersion": ...,
        "NumberOfBrokerNodes": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ProvisionedTypeDef

def get_value() -> ProvisionedTypeDef:
    return {
        "BrokerNodeGroupInfo": ...,
        "NumberOfBrokerNodes": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ClusterOperationInfoTypeDef

def get_value() -> ClusterOperationInfoTypeDef:
    return {
        "ClientRequestId": ...,
    }
# 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

DescribeClusterResponseTypeDef#

# DescribeClusterResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeClusterResponseTypeDef

def get_value() -> DescribeClusterResponseTypeDef:
    return {
        "ClusterInfo": ...,
        "ResponseMetadata": ...,
    }
# DescribeClusterResponseTypeDef definition

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

ListClustersResponseTypeDef#

# ListClustersResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClustersResponseTypeDef

def get_value() -> ListClustersResponseTypeDef:
    return {
        "ClusterInfoList": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListClustersResponseTypeDef definition

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

CreateClusterV2RequestRequestTypeDef#

# CreateClusterV2RequestRequestTypeDef usage example

from mypy_boto3_kafka.type_defs import CreateClusterV2RequestRequestTypeDef

def get_value() -> CreateClusterV2RequestRequestTypeDef:
    return {
        "ClusterName": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import ClusterTypeDef

def get_value() -> ClusterTypeDef:
    return {
        "ActiveOperationArn": ...,
    }
# 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 usage example

from mypy_boto3_kafka.type_defs import DescribeClusterOperationResponseTypeDef

def get_value() -> DescribeClusterOperationResponseTypeDef:
    return {
        "ClusterOperationInfo": ...,
        "ResponseMetadata": ...,
    }
# DescribeClusterOperationResponseTypeDef definition

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

ListClusterOperationsResponseTypeDef#

# ListClusterOperationsResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClusterOperationsResponseTypeDef

def get_value() -> ListClusterOperationsResponseTypeDef:
    return {
        "ClusterOperationInfoList": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListClusterOperationsResponseTypeDef definition

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

DescribeClusterV2ResponseTypeDef#

# DescribeClusterV2ResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import DescribeClusterV2ResponseTypeDef

def get_value() -> DescribeClusterV2ResponseTypeDef:
    return {
        "ClusterInfo": ...,
        "ResponseMetadata": ...,
    }
# DescribeClusterV2ResponseTypeDef definition

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

ListClustersV2ResponseTypeDef#

# ListClustersV2ResponseTypeDef usage example

from mypy_boto3_kafka.type_defs import ListClustersV2ResponseTypeDef

def get_value() -> ListClustersV2ResponseTypeDef:
    return {
        "ClusterInfoList": ...,
        "NextToken": ...,
        "ResponseMetadata": ...,
    }
# ListClustersV2ResponseTypeDef definition

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