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],
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)
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)
- See ClusterStateType
- See ClusterTypeType
- 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)
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)
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)
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)
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)
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)
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)
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],
- 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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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],
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)
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)
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],
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],
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],
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)
- See CloudWatchLogsTypeDef
- See FirehoseTypeDef
- 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]],
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)
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],
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)
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,
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)
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)
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)
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)
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)
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)
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)
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)
- 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)
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)
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)
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)
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)
- See ScramTypeDef
- 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],
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
- See SaslTypeDef
- See TlsTypeDef
- 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)
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)
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)
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)
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)
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)
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)
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)
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]],
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)
- See BrokerEBSVolumeInfoTypeDef
- See ConfigurationInfoTypeDef
- See EnhancedMonitoringType
- See OpenMonitoringTypeDef
- See LoggingInfoTypeDef
- See ClientAuthenticationTypeDef
- See EncryptionInfoTypeDef
- See ConnectivityInfoTypeDef
- 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,
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)
- See BrokerNodeGroupInfoTypeDef
- See ClientAuthenticationTypeDef
- See BrokerSoftwareInfoTypeDef
- See EncryptionInfoTypeDef
- See EnhancedMonitoringType
- See OpenMonitoringTypeDef
- See LoggingInfoTypeDef
- See ClusterStateType
- See StateInfoTypeDef
- 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)
- See BrokerNodeGroupInfoTypeDef
- See ClientAuthenticationTypeDef
- See ConfigurationInfoTypeDef
- See EncryptionInfoTypeDef
- See EnhancedMonitoringType
- See OpenMonitoringInfoTypeDef
- See LoggingInfoTypeDef
- 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)
- See BrokerNodeGroupInfoTypeDef
- See ClientAuthenticationTypeDef
- See ConfigurationInfoTypeDef
- See EncryptionInfoTypeDef
- See EnhancedMonitoringType
- See OpenMonitoringInfoTypeDef
- See LoggingInfoTypeDef
- 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)
- See BrokerNodeGroupInfoTypeDef
- See BrokerSoftwareInfoTypeDef
- See ClientAuthenticationTypeDef
- See EncryptionInfoTypeDef
- See EnhancedMonitoringType
- See OpenMonitoringInfoTypeDef
- See LoggingInfoTypeDef
- 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)
- See ErrorInfoTypeDef
- See ClusterOperationStepTypeDef
- See MutableClusterInfoTypeDef
- See MutableClusterInfoTypeDef
- 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)
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)
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)
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)
- See ClusterTypeType
- See ClusterStateType
- See StateInfoTypeDef
- See ProvisionedTypeDef
- 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)
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)
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)
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)