Package com.bakdata.kafka.consumer

Class ConsumerTopicConfig

java.lang.Object
com.bakdata.kafka.consumer.ConsumerTopicConfig
public final class ConsumerTopicConfig extends Object
Provides topic configuration for a ConsumerApp

  • 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

    • builder

      public static ConsumerTopicConfig.ConsumerTopicConfigBuilder 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

    • 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