Class ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder
java.lang.Object
com.bakdata.kafka.consumerproducer.ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder
- Enclosing class:
- ConsumerProducerTopicConfig
-
Method Summary
Modifier and TypeMethodDescriptionbuild()errorTopic(String errorTopic) inputPattern(Pattern inputPattern) inputTopics(@NonNull List<String> inputTopics) labeledInputPatterns(@NonNull Map<String, Pattern> labeledInputPatterns) Input patterns that are identified by a labellabeledInputTopics(@NonNull Map<String, List<String>> labeledInputTopics) Input topics that are identified by a labellabeledOutputTopics(@NonNull Map<String, String> labeledOutputTopics) Output topics that are identified by a labeloutputTopic(String outputTopic) toString()
-
Method Details
-
inputTopics
public ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder inputTopics(@NonNull @NonNull List<String> inputTopics) - Returns:
this.
-
labeledInputTopics
public ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder labeledInputTopics(@NonNull @NonNull Map<String, List<String>> labeledInputTopics) Input topics that are identified by a label- Returns:
this.
-
inputPattern
public ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder inputPattern(Pattern inputPattern) - Returns:
this.
-
labeledInputPatterns
public ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder labeledInputPatterns(@NonNull @NonNull Map<String, Pattern> labeledInputPatterns) Input patterns that are identified by a label- Returns:
this.
-
outputTopic
public ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder outputTopic(String outputTopic) - Returns:
this.
-
labeledOutputTopics
public ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder labeledOutputTopics(@NonNull @NonNull Map<String, String> labeledOutputTopics) Output topics that are identified by a label- Returns:
this.
-
errorTopic
- Returns:
this.
-
build
-
toString
-