Package io.streamthoughts.azkarra.runtime.streams.topology

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.