future.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION,
"Final submit was timed out by the test provider or was interrupted", cause).build());
future.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION,
"Final submit was timed out by the test provider or was interrupted", cause).build());