{@inheritDoc}

List Bootstrap brokers for the supplied cluster_name or or current cluster name or all clusters

Gets the Apache Kafka versions to which you can update the MSK cluster

Describe the supplied cluster_name or or current cluster name or all clusters

Describe the supplied cluster_name or or current cluster name or all clusters

List session information like clusters, selected cluster

Returns a list of all the operations that have been performed on the specified MSK cluster.

Returns a list of all the MSK configurations in this Region

Returns a list of Apache Kafka versions

Returns a list of the broker nodes in the cluster

Returns a list of the Scram Secrets associated with an Amazon MSK cluster

Quits the program.

Reboots brokers

Set the current cluster to the specified name if valid

Lists the topics in the current cluster

Updates the number of broker nodes in the cluster

Parameters: - session

Parameters: - session

Parameters: - id

Parameters: - id

Handles '/daemondownload' (downloading specific daemon log file) request.

Handles '/dumps' (downloading specific dump file) request.

Handles '/download' (downloading specific log file) request.

Dump a string to a file. @param location where to write to @param data the data to write @throws IOException on any error

Emits a new tuple to the specified output stream with the given message ID. When Storm detects that this tuple has been fully processed, or has failed