public KafkaFuture<Void> all() {
        return addTopologyFuture;
    }
@return a {@link KafkaFuture} that completes successfully when all threads on this client have picked up the
new {@link NamedTopology}. Note that the new topology is not guaranteed to begin processing on this client or
any others until its addition has been completed by all instances of the application.
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/AddNamedTopologyResult.java