Class TopologyUtils


  • public class TopologyUtils
    extends Object
    • Constructor Detail

      • TopologyUtils

        public TopologyUtils()
    • Method Detail

      • getSourceTopics

        public static Set<String> getSourceTopics​(org.apache.kafka.streams.TopologyDescription topology)
      • getSinkTopics

        public static Set<String> getSinkTopics​(org.apache.kafka.streams.TopologyDescription topology)
      • getUserDeclaredTopics

        public static Set<String> getUserDeclaredTopics​(org.apache.kafka.streams.TopologyDescription topology)
      • isInternalTopic

        public static boolean isInternalTopic​(String applicationId,
                                              String topic)
        Checks whether the specified topic is internal for the given application id.
        Parameters:
        applicationId - the id of the application.
        topic - the name of the topic.
        Returns:
        true if topic is internal, otherwise false.
      • isInternalTopic

        public static boolean isInternalTopic​(String topic)
        Checks whether the specified topic is internal.
        Parameters:
        topic - the name of the topic.
        Returns:
        true if topic is internal, otherwise false.