def describe_log_dirs(self):
        """Send a DescribeLogDirsRequest request to a broker.

        Returns:
            A message future
        """
        version = self._client.api_version(DescribeLogDirsRequest, max_version=0)
        if version <= 0:
            request = DescribeLogDirsRequest[version]()
            future = self._send_request_to_node(self._client.least_loaded_node(), request)
            self._wait_for_futures([future])
        else:
            raise NotImplementedError(
                "Support for DescribeLogDirsRequest_v{} has not yet been added to KafkaAdminClient."
                    .format(version))
        return future.value
Send a DescribeLogDirsRequest request to a broker.

        Returns:
            A message future
        
kafka/admin/client.py