public InternalTopologyBuilder getInternalBuilder(final String applicationId) {
        return internalTopologyBuilder.rewriteTopology(new StreamsConfig(StreamsTestUtils.getStreamsConfig(applicationId)));
    }
This class allows to access the {@link InternalTopologyBuilder} a {@link Topology} object.
streams/src/test/java/org/apache/kafka/streams/TopologyWrapper.java