@Override
        public CompletableFuture<AppendResult> append(AppendContext context, RecordBatch recordBatch) {
            return stream.append(context, recordBatch).whenComplete((rst, ex) -> {
                if (ex != null) {
                    LOGGER.error("Appending to stream[{}] failed, retry later", streamId(), ex);
                }
            });
        }
Maybe halt and complete the waiting future if the exception is a ElasticStreamClientException with a halt error code.

@param t             the exception
@param waitingFuture the waiting future
@return true if the waiting future is completed, otherwise false
core/src/main/scala/kafka/log/streamaspect/ClientWrapper.java