Package com.bakdata.kafka.mixin

Class InputOptions

java.lang.Object
com.bakdata.kafka.mixin.InputOptions
public class InputOptions extends Object
Shared CLI options to configure Kafka applications that consume input data.

  • Constructor Details

    • InputOptions

      public InputOptions()

  • Method Details

    • getInputTopics

      public List<String> getInputTopics()

    • getInputPattern

      public Pattern getInputPattern()

    • getLabeledInputTopics

      public Map<String,List<String>> getLabeledInputTopics()

    • getLabeledInputPatterns

      public Map<String,Pattern> getLabeledInputPatterns()

    • setInputTopics

      public void setInputTopics(List<String> inputTopics)

    • setInputPattern

      public void setInputPattern(Pattern inputPattern)

    • setLabeledInputTopics

      public void setLabeledInputTopics(Map<String,List<String>> labeledInputTopics)

    • setLabeledInputPatterns

      public void setLabeledInputPatterns(Map<String,Pattern> labeledInputPatterns)

    • equals

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

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object