public void completeExceptional() {
        this.future.completeExceptionally(new RuntimeException("exceed max retry "
                + retryTime + " adding"));
    }
when topic operation finished, complete it.
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/TopicFuture.java