Kafka module#
Index > Kafka
Auto-generated documentation for Kafka type annotations stubs module mypy-boto3-kafka.
How to install#
Generate locally (recommended)#
You can generate type annotations for boto3
package locally with mypy_boto3_builder
.
Use uv for build isolation.
- Run mypy-boto3-builder in your package root directory:
uvx --with 'boto3==1.35.86' mypy_boto3_builder
- Select
boto3-stubs
AWS SDK. - Add
Kafka
service. - Use provided commands to install generated packages.
VSCode extension#
Add AWS Boto3
extension to your VSCode and run AWS boto3: Quick Start
command.
Click Modify
and select boto3 common
and Kafka
.
From PyPI with pip#
Install boto3-stubs
for Kafka
service.
# install with boto3 type annotations
python -m pip install 'boto3-stubs[kafka]'
# Lite version does not provide session.client/resource overloads
# it is more RAM-friendly, but requires explicit type annotations
python -m pip install 'boto3-stubs-lite[kafka]'
# standalone installation
python -m pip install mypy-boto3-kafka
How to uninstall#
python -m pip uninstall -y mypy-boto3-kafka
Usage#
Code samples can be found in Examples.
KafkaClient#
Type annotations and code completion for boto3.client("kafka")
as KafkaClient
boto3 documentation
# KafkaClient usage example
from boto3.session import Session
from mypy_boto3_kafka.client import KafkaClient
def get_client() -> KafkaClient:
return Session().client("kafka")
Paginators#
Type annotations and code completion for paginators
from boto3.client("kafka").get_paginator("...")
.
# ListClientVpcConnectionsPaginator usage example
from boto3.session import Session
from mypy_boto3_kafka.paginator import ListClientVpcConnectionsPaginator
def get_list_client_vpc_connections_paginator() -> ListClientVpcConnectionsPaginator:
return Session().client("kafka").get_paginator("list_client_vpc_connections"))
- ListClientVpcConnectionsPaginator
- ListClusterOperationsPaginator
- ListClusterOperationsV2Paginator
- ListClustersPaginator
- ListClustersV2Paginator
- ListConfigurationRevisionsPaginator
- ListConfigurationsPaginator
- ListKafkaVersionsPaginator
- ListNodesPaginator
- ListReplicatorsPaginator
- ListScramSecretsPaginator
- ListVpcConnectionsPaginator
Literals#
Type annotations for literals used in methods and schema.
# BrokerAZDistributionType usage example
from mypy_boto3_kafka.literals import BrokerAZDistributionType
def get_value() -> BrokerAZDistributionType:
return "DEFAULT"
- BrokerAZDistributionType
- ClientBrokerType
- ClusterStateType
- ClusterTypeType
- ConfigurationStateType
- CustomerActionStatusType
- EnhancedMonitoringType
- KafkaVersionStatusType
- ListClientVpcConnectionsPaginatorName
- ListClusterOperationsPaginatorName
- ListClusterOperationsV2PaginatorName
- ListClustersPaginatorName
- ListClustersV2PaginatorName
- ListConfigurationRevisionsPaginatorName
- ListConfigurationsPaginatorName
- ListKafkaVersionsPaginatorName
- ListNodesPaginatorName
- ListReplicatorsPaginatorName
- ListScramSecretsPaginatorName
- ListVpcConnectionsPaginatorName
- NodeTypeType
- ReplicationStartingPositionTypeType
- ReplicationTopicNameConfigurationTypeType
- ReplicatorStateType
- StorageModeType
- TargetCompressionTypeType
- UserIdentityTypeType
- VpcConnectionStateType
- KafkaServiceName
- ServiceName
- ResourceServiceName
- PaginatorName
- RegionName
Type definitions#
Type annotations for type definitions used in methods and schema.
- AmazonMskClusterTypeDef
- BatchAssociateScramSecretRequestRequestTypeDef
- ResponseMetadataTypeDef
- UnprocessedScramSecretTypeDef
- BatchDisassociateScramSecretRequestRequestTypeDef
- BlobTypeDef
- BrokerCountUpdateInfoTypeDef
- ProvisionedThroughputTypeDef
- CloudWatchLogsTypeDef
- FirehoseTypeDef
- S3TypeDef
- BrokerSoftwareInfoTypeDef
- TlsOutputTypeDef
- UnauthenticatedTypeDef
- ClientVpcConnectionTypeDef
- StateInfoTypeDef
- ErrorInfoTypeDef
- ClusterOperationStepInfoTypeDef
- ClusterOperationV2SummaryTypeDef
- CompatibleKafkaVersionTypeDef
- ConfigurationInfoTypeDef
- ConfigurationRevisionTypeDef
- PublicAccessTypeDef
- ConsumerGroupReplicationOutputTypeDef
- ConsumerGroupReplicationTypeDef
- ConsumerGroupReplicationUpdateTypeDef
- ControllerNodeInfoTypeDef
- CreateVpcConnectionRequestRequestTypeDef
- DeleteClusterPolicyRequestRequestTypeDef
- DeleteClusterRequestRequestTypeDef
- DeleteConfigurationRequestRequestTypeDef
- DeleteReplicatorRequestRequestTypeDef
- DeleteVpcConnectionRequestRequestTypeDef
- DescribeClusterOperationRequestRequestTypeDef
- DescribeClusterOperationV2RequestRequestTypeDef
- DescribeClusterRequestRequestTypeDef
- DescribeClusterV2RequestRequestTypeDef
- DescribeConfigurationRequestRequestTypeDef
- DescribeConfigurationRevisionRequestRequestTypeDef
- DescribeReplicatorRequestRequestTypeDef
- ReplicationStateInfoTypeDef
- DescribeVpcConnectionRequestRequestTypeDef
- EncryptionAtRestTypeDef
- EncryptionInTransitTypeDef
- GetBootstrapBrokersRequestRequestTypeDef
- GetClusterPolicyRequestRequestTypeDef
- GetCompatibleKafkaVersionsRequestRequestTypeDef
- IamTypeDef
- JmxExporterInfoTypeDef
- JmxExporterTypeDef
- KafkaClusterClientVpcConfigOutputTypeDef
- KafkaClusterClientVpcConfigTypeDef
- KafkaVersionTypeDef
- PaginatorConfigTypeDef
- ListClientVpcConnectionsRequestRequestTypeDef
- ListClusterOperationsRequestRequestTypeDef
- ListClusterOperationsV2RequestRequestTypeDef
- ListClustersRequestRequestTypeDef
- ListClustersV2RequestRequestTypeDef
- ListConfigurationRevisionsRequestRequestTypeDef
- ListConfigurationsRequestRequestTypeDef
- ListKafkaVersionsRequestRequestTypeDef
- ListNodesRequestRequestTypeDef
- ListReplicatorsRequestRequestTypeDef
- ListScramSecretsRequestRequestTypeDef
- ListTagsForResourceRequestRequestTypeDef
- ListVpcConnectionsRequestRequestTypeDef
- VpcConnectionTypeDef
- NodeExporterInfoTypeDef
- NodeExporterTypeDef
- ZookeeperNodeInfoTypeDef
- PutClusterPolicyRequestRequestTypeDef
- RebootBrokerRequestRequestTypeDef
- RejectClientVpcConnectionRequestRequestTypeDef
- ReplicationInfoSummaryTypeDef
- ReplicationStartingPositionTypeDef
- ReplicationTopicNameConfigurationTypeDef
- ScramTypeDef
- VpcConfigOutputTypeDef
- TagResourceRequestRequestTypeDef
- TlsTypeDef
- TopicReplicationUpdateTypeDef
- UntagResourceRequestRequestTypeDef
- UpdateBrokerCountRequestRequestTypeDef
- UpdateBrokerTypeRequestRequestTypeDef
- UserIdentityTypeDef
- VpcConfigTypeDef
- VpcConnectivityTlsTypeDef
- VpcConnectivityIamTypeDef
- VpcConnectivityScramTypeDef
- KafkaClusterSummaryTypeDef
- CreateClusterResponseTypeDef
- CreateClusterV2ResponseTypeDef
- CreateReplicatorResponseTypeDef
- CreateVpcConnectionResponseTypeDef
- DeleteClusterResponseTypeDef
- DeleteConfigurationResponseTypeDef
- DeleteReplicatorResponseTypeDef
- DeleteVpcConnectionResponseTypeDef
- DescribeConfigurationRevisionResponseTypeDef
- DescribeVpcConnectionResponseTypeDef
- EmptyResponseMetadataTypeDef
- GetBootstrapBrokersResponseTypeDef
- GetClusterPolicyResponseTypeDef
- ListScramSecretsResponseTypeDef
- ListTagsForResourceResponseTypeDef
- PutClusterPolicyResponseTypeDef
- RebootBrokerResponseTypeDef
- UpdateBrokerCountResponseTypeDef
- UpdateBrokerStorageResponseTypeDef
- UpdateBrokerTypeResponseTypeDef
- UpdateClusterConfigurationResponseTypeDef
- UpdateClusterKafkaVersionResponseTypeDef
- UpdateConnectivityResponseTypeDef
- UpdateMonitoringResponseTypeDef
- UpdateReplicationInfoResponseTypeDef
- UpdateSecurityResponseTypeDef
- UpdateStorageResponseTypeDef
- BatchAssociateScramSecretResponseTypeDef
- BatchDisassociateScramSecretResponseTypeDef
- CreateConfigurationRequestRequestTypeDef
- UpdateConfigurationRequestRequestTypeDef
- BrokerEBSVolumeInfoTypeDef
- EBSStorageInfoTypeDef
- UpdateStorageRequestRequestTypeDef
- BrokerLogsTypeDef
- BrokerNodeInfoTypeDef
- ListClientVpcConnectionsResponseTypeDef
- ClusterOperationStepTypeDef
- ListClusterOperationsV2ResponseTypeDef
- GetCompatibleKafkaVersionsResponseTypeDef
- UpdateClusterConfigurationRequestRequestTypeDef
- UpdateClusterKafkaVersionRequestRequestTypeDef
- ConfigurationTypeDef
- CreateConfigurationResponseTypeDef
- DescribeConfigurationResponseTypeDef
- ListConfigurationRevisionsResponseTypeDef
- UpdateConfigurationResponseTypeDef
- ConsumerGroupReplicationUnionTypeDef
- EncryptionInfoTypeDef
- ServerlessSaslTypeDef
- KafkaClusterDescriptionTypeDef
- KafkaClusterClientVpcConfigUnionTypeDef
- ListKafkaVersionsResponseTypeDef
- ListClientVpcConnectionsRequestPaginateTypeDef
- ListClusterOperationsRequestPaginateTypeDef
- ListClusterOperationsV2RequestPaginateTypeDef
- ListClustersRequestPaginateTypeDef
- ListClustersV2RequestPaginateTypeDef
- ListConfigurationRevisionsRequestPaginateTypeDef
- ListConfigurationsRequestPaginateTypeDef
- ListKafkaVersionsRequestPaginateTypeDef
- ListNodesRequestPaginateTypeDef
- ListReplicatorsRequestPaginateTypeDef
- ListScramSecretsRequestPaginateTypeDef
- ListVpcConnectionsRequestPaginateTypeDef
- ListVpcConnectionsResponseTypeDef
- PrometheusInfoTypeDef
- PrometheusTypeDef
- TopicReplicationOutputTypeDef
- TopicReplicationTypeDef
- SaslTypeDef
- TlsUnionTypeDef
- UpdateReplicationInfoRequestRequestTypeDef
- VpcConnectionInfoServerlessTypeDef
- VpcConnectionInfoTypeDef
- VpcConfigUnionTypeDef
- VpcConnectivitySaslTypeDef
- ReplicatorSummaryTypeDef
- UpdateBrokerStorageRequestRequestTypeDef
- StorageInfoTypeDef
- LoggingInfoTypeDef
- NodeInfoTypeDef
- ListConfigurationsResponseTypeDef
- ServerlessClientAuthenticationTypeDef
- KafkaClusterTypeDef
- OpenMonitoringInfoTypeDef
- OpenMonitoringTypeDef
- ReplicationInfoDescriptionTypeDef
- TopicReplicationUnionTypeDef
- ClientAuthenticationOutputTypeDef
- ClientAuthenticationTypeDef
- ClusterOperationV2ServerlessTypeDef
- VpcConnectivityClientAuthenticationTypeDef
- ListReplicatorsResponseTypeDef
- ListNodesResponseTypeDef
- ServerlessRequestTypeDef
- ServerlessTypeDef
- UpdateMonitoringRequestRequestTypeDef
- DescribeReplicatorResponseTypeDef
- ReplicationInfoTypeDef
- ClientAuthenticationUnionTypeDef
- UpdateSecurityRequestRequestTypeDef
- VpcConnectivityTypeDef
- CreateReplicatorRequestRequestTypeDef
- ConnectivityInfoTypeDef
- BrokerNodeGroupInfoOutputTypeDef
- BrokerNodeGroupInfoTypeDef
- MutableClusterInfoTypeDef
- UpdateConnectivityRequestRequestTypeDef
- ClusterInfoTypeDef
- ProvisionedTypeDef
- BrokerNodeGroupInfoUnionTypeDef
- CreateClusterRequestRequestTypeDef
- ClusterOperationInfoTypeDef
- ClusterOperationV2ProvisionedTypeDef
- DescribeClusterResponseTypeDef
- ListClustersResponseTypeDef
- ClusterTypeDef
- ProvisionedRequestTypeDef
- DescribeClusterOperationResponseTypeDef
- ListClusterOperationsResponseTypeDef
- ClusterOperationV2TypeDef
- DescribeClusterV2ResponseTypeDef
- ListClustersV2ResponseTypeDef
- CreateClusterV2RequestRequestTypeDef
- DescribeClusterOperationV2ResponseTypeDef