public TaskConfig getTaskConfigFor(final TaskId taskId) {
        final InternalTopologyBuilder builder = lookupBuilderForTask(taskId);
        return builder.topologyConfigs().getTaskConfig();
    }
Removes the topology and registers a future that listens for all threads on the older version to see the update
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java