docs: def delete_topics(self, topics, timeout_ms=None):
          """Delete topics from the cluster.
  
          :param topics: A list of topic name strings.
          :param timeout_ms: Milliseconds to wait for topics to be deleted
              before the broker returns.
          :return: Appropriate version of DeleteTopicsResponse class.
          """
          version = self._matching_api_version(DeleteTopicsRequest)
          timeout_ms = self._validate_timeout(timeout_ms)
          if version <= 1:
              request = DeleteTopicsRequest[version](
                  topics=topics,
                  timeout=timeout_ms
              )
              response = self._send_request_to_controller(request)
          else:
              raise NotImplementedError(
                  "Support for DeleteTopics v{} has not yet been added to KafkaAdminClient."
                  .format(version))
          return response