public CompletableFuture < ConsumeResponse > consume ( ConsumeRequest request ) { logRequest ( request ) ; return CompletableFuture . completedFuture ( logResponse ( ConsumeResponse . error ( ) ) ) ; }
Handles a consume request .