deleteTopic method

Future<DeleteTopicResponse> deleteTopic({ required String clusterArn, required String topicName, })

Deletes a topic in the specified MSK cluster.

May throw BadRequestException. May throw ClusterConnectivityException. May throw ControllerMovedException. May throw ForbiddenException. May throw GroupSubscribedToTopicException. May throw InternalServerErrorException. May throw KafkaRequestException. May throw KafkaTimeoutException. May throw NotControllerException. May throw NotFoundException. May throw ReassignmentInProgressException. May throw UnknownTopicOrPartitionException.

Parameter clusterArn : The Amazon Resource Name (ARN) that uniquely identifies the cluster.

Parameter topicName : The name of the topic to delete.

Implementation

Future<DeleteTopicResponse> deleteTopic({
  required String clusterArn,
  required String topicName,
}) async {
  final response = await _protocol.send(
    payload: null,
    method: 'DELETE',
    requestUri:
        '/v1/clusters/${Uri.encodeComponent(clusterArn)}/topics/${Uri.encodeComponent(topicName)}',
    exceptionFnMap: _exceptionFns,
  );
  return DeleteTopicResponse.fromJson(response);
}