Kafka#
Client#
- class Kafka.Client#
A low-level client representing Managed Streaming for Kafka
The operations for managing an Amazon MSK cluster.
import boto3 client = boto3.client('kafka')
These are the available methods:
- batch_associate_scram_secret
- batch_disassociate_scram_secret
- can_paginate
- close
- create_cluster
- create_cluster_v2
- create_configuration
- create_vpc_connection
- delete_cluster
- delete_cluster_policy
- delete_configuration
- delete_vpc_connection
- describe_cluster
- describe_cluster_operation
- describe_cluster_v2
- describe_configuration
- describe_configuration_revision
- describe_vpc_connection
- get_bootstrap_brokers
- get_cluster_policy
- get_compatible_kafka_versions
- get_paginator
- get_waiter
- list_client_vpc_connections
- list_cluster_operations
- list_clusters
- list_clusters_v2
- list_configuration_revisions
- list_configurations
- list_kafka_versions
- list_nodes
- list_scram_secrets
- list_tags_for_resource
- list_vpc_connections
- put_cluster_policy
- reboot_broker
- reject_client_vpc_connection
- tag_resource
- untag_resource
- update_broker_count
- update_broker_storage
- update_broker_type
- update_cluster_configuration
- update_cluster_kafka_version
- update_configuration
- update_connectivity
- update_monitoring
- update_security
- update_storage
Paginators#
Paginators are available on a client instance via the get_paginator method. For more detailed instructions and examples on the usage of paginators, see the paginators user guide.
The available paginators are: