code: public CompletableFuture<ConsumeResponse> consume(ConsumeRequest request) {
      logRequest(request);
      return CompletableFuture.completedFuture(logResponse(ConsumeResponse.error()));
    }
docs: Handles a consume request.
  
  @param request the consume request
  @return future to be completed with the consume response