public final KafkaFuture<Void> all() {
        if (resetOffsetsFuture == null) {
            return removeTopologyFuture;
        } else {
            return resetOffsetsFuture;
        }
    }
@return a {@link KafkaFuture} that completes successfully when all threads on this client have removed the
corresponding {@link NamedTopology} and all source topic offsets have been deleted (if applicable). At this
point no more of its tasks will be processed by the current client, but there may still be other clients which
do. It is only guaranteed that this {@link NamedTopology} has fully stopped processing when all clients have
successfully completed their corresponding {@link KafkaFuture}.
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/RemoveNamedTopologyResult.java