Package com.bakdata.kafka.streams

Class StreamsTopicConfig

java.lang.Object
com.bakdata.kafka.streams.StreamsTopicConfig
public final class StreamsTopicConfig extends Object
Provides topic configuration for a StreamsApp

  • Method Details

    • getInputTopics

      public List<String> getInputTopics(String label)
      Get input topics for a specified label
      Parameters:
      label - label of input topics
      Returns:
      topic names

    • getInputPattern

      public Pattern getInputPattern(String label)
      Get input pattern for a specified label
      Parameters:
      label - label of input pattern
      Returns:
      topic pattern

    • getOutputTopic

      public String getOutputTopic(String label)
      Get output topic for a specified label
      Parameters:
      label - label of output topic
      Returns:
      topic name

    • builder

      public static StreamsTopicConfig.StreamsTopicConfigBuilder builder()

    • getInputTopics

      @NonNull public @NonNull List<String> getInputTopics()

    • getLabeledInputTopics

      @NonNull public @NonNull Map<String,List<String>> getLabeledInputTopics()
      Input topics that are identified by a label

    • getInputPattern

      public Pattern getInputPattern()

    • getLabeledInputPatterns

      @NonNull public @NonNull Map<String,Pattern> getLabeledInputPatterns()
      Input patterns that are identified by a label

    • getOutputTopic

      public String getOutputTopic()

    • getLabeledOutputTopics

      @NonNull public @NonNull Map<String,String> getLabeledOutputTopics()
      Output topics that are identified by a label

    • getErrorTopic

      public String getErrorTopic()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object