Page History

    interface Processor extends Node {
        /**
         * The names of all connected stores.
         * @return set of store names
         */
        @Deprecated
        Set<String> stores();

        /**
         * The namesset of all connected stores.
         * @return set of stores
         */
        Set<Store> storeSet();                    <---- NEW FUNC
    }

    /**
     * A state store of a topology                    <---- NEW CLASS
     */
    interface Store {
        /**
         * Name of the stat store
         */
        String name();

        /**
         * Name of the corresponding changelog topic of this store.
         * @return name of the changelog topic; null if the store is not logging enabled
         */
        String changelogTopic();

        /**
         * Names of serde classes that are associated with the store
         */
        List<String> serdeNames();
    }

    interface Source extends Node {
        ....

        /**
         * Names of key serde class used for this source node
         */
        String keySerdeName();                    <---- NEW FUNC

        /**
         * Names of value serde class used for this source node
         */
        String valueSerdeName();                    <---- NEW FUNC
    }

    interface Sink extends Node {
        ....

        /**
         * Names of key serde class used for this source node
         */
        String keySerdeName();                    <---- NEW FUNC

        /**
         * Names of value serde class used for this source node
         */
        String valueSerdeName();                    <---- NEW FUNC
    }

    interface Subtopology {
        /**
         * Internally assigned unique ID.
         * @return the ID of the sub-topology
         */
        int id();

        /**
         * All nodes of this sub-topology.
         * @return set of all nodes within the sub-topology
         */
        Set<Node> nodes();

        /**
         * All source nodes of this sub-topology.
         * @return set of all source nodes within the sub-topology
         */
        Set<Source> sourceNodes();

        /**
         * All sink nodes of this sub-topology.
         * @return set of all sink nodes within the sub-topology
         */
        Set<Sink> sinkNodes();

        /**
         * All state stores of this sub-topology.
         * @return set of all state stores within the sub-topology
         */
        Set<Store> stores();                    <---- NEW FUNC
    }