kafka

class moto.kafka.models.KafkaBackend(region_name: str, account_id: str)

Implementation of Kafka APIs.

Implemented features for this service

• [ ] batch_associate_scram_secret

• [ ] batch_disassociate_scram_secret

• [X] create_cluster

• [X] create_cluster_v2

• [ ] create_configuration

• [ ] create_replicator

• [ ] create_vpc_connection

• [X] delete_cluster

• [ ] delete_cluster_policy

• [ ] delete_configuration

• [ ] delete_replicator

• [ ] delete_vpc_connection

• [X] describe_cluster

• [ ] describe_cluster_operation

• [ ] describe_cluster_operation_v2

• [X] describe_cluster_v2

• [ ] describe_configuration

• [ ] describe_configuration_revision

• [ ] describe_replicator

• [ ] describe_vpc_connection

• [ ] get_bootstrap_brokers

• [ ] get_cluster_policy

• [ ] get_compatible_kafka_versions

• [ ] list_client_vpc_connections

• [ ] list_cluster_operations

• [ ] list_cluster_operations_v2

• [X] list_clusters

• [X] list_clusters_v2

• [ ] list_configuration_revisions

• [ ] list_configurations

• [ ] list_kafka_versions

• [ ] list_nodes

• [ ] list_replicators

• [ ] list_scram_secrets

• [X] list_tags_for_resource

• [ ] list_vpc_connections

• [ ] put_cluster_policy

• [ ] reboot_broker

• [ ] reject_client_vpc_connection

• [X] tag_resource

• [X] 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