public finalinterface class TopologyDescription {
    public final Set<Subtopology> subtopologies();
    public final Set<GlobalStore> globalStores();

    public final classinferface Subtopology {
        public final int id();
        public final Set<Node> nodes();
    }

    public finalinterface class GlobalStore {
        public final Source source();
        public final Processor processor();
    }

    public interface Node {
        String name()
        Set<Node> getPredecessorspredecessors();
        Set<Node> getSuccessorssuccessors();
    }

    publicinterface final class Source implementsextends Node {
        public final String topics(); // can be comma separated list of topic names or pattern (as String)
    }

    publicinterface final class Processor implementsextends Node {
        public final Set<String> stores();
    }

    public final classinterface Sink implementsextends Node {
        public final String topic();
    }

}