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_replicator
- create_vpc_connection
- delete_cluster
- delete_cluster_policy
- delete_configuration
- delete_replicator
- delete_vpc_connection
- describe_cluster
- describe_cluster_operation
- describe_cluster_operation_v2
- describe_cluster_v2
- describe_configuration
- describe_configuration_revision
- describe_replicator
- 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_cluster_operations_v2
- list_clusters
- list_clusters_v2
- list_configuration_revisions
- list_configurations
- list_kafka_versions
- list_nodes
- list_replicators
- 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_replication_info
- update_security
- update_storage
Client Exceptions#
Client exceptions are available on a client instance via the exceptions property. For more detailed instructions and examples on the exact usage of client exceptions, see the error handling user guide.
The available client exceptions are:
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: