Type annotations for boto3 Kafka

1.42.65 · active · verified Sat Apr 11

mypy-boto3-kafka provides type annotations for the AWS boto3 Kafka service. It is a generated library, currently at version 1.42.65, built with mypy-boto3-builder 8.12.0. Its release cadence generally follows updates to the underlying boto3 library and the builder.

Warnings

Install

Imports

Quickstart

Demonstrates how to import and use the KafkaClient type stub with a standard boto3 session to get type-hinted AWS MSK operations.

import os
import boto3
from mypy_boto3_kafka import KafkaClient

# Ensure boto3 is configured, e.g., via AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_REGION_NAME env vars

region = os.environ.get('AWS_REGION_NAME', 'us-east-1')

def get_kafka_client() -> KafkaClient:
    session = boto3.Session(region_name=region)
    client: KafkaClient = session.client('kafka')
    return client

kafka_client = get_kafka_client()
response = kafka_client.list_clusters_v2()

print(f"Kafka Clusters: {response.get('ClusterInfoList')}")

view raw JSON →