Package com.bakdata.kafka.consumer

Class ConsumerTopicConfig.ConsumerTopicConfigBuilder

java.lang.Object

com.bakdata.kafka.consumer.ConsumerTopicConfig.ConsumerTopicConfigBuilder

Enclosing class:

ConsumerTopicConfig

public static class ConsumerTopicConfig.ConsumerTopicConfigBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
ConsumerTopicConfig	build()
ConsumerTopicConfig.ConsumerTopicConfigBuilder	inputPattern(Pattern inputPattern)
ConsumerTopicConfig.ConsumerTopicConfigBuilder	inputTopics(@NonNull List<String> inputTopics)
ConsumerTopicConfig.ConsumerTopicConfigBuilder	labeledInputPatterns(@NonNull Map<String,Pattern> labeledInputPatterns)	Input patterns that are identified by a label
ConsumerTopicConfig.ConsumerTopicConfigBuilder	labeledInputTopics(@NonNull Map<String,List<String>> labeledInputTopics)	Input topics that are identified by a label
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

inputTopics

public ConsumerTopicConfig.ConsumerTopicConfigBuilder inputTopics(@NonNull
 @NonNull List<String> inputTopics)

Returns:

this.

labeledInputTopics

public ConsumerTopicConfig.ConsumerTopicConfigBuilder labeledInputTopics(@NonNull
 @NonNull Map<String,List<String>> labeledInputTopics)

Input topics that are identified by a label

Returns:

this.

inputPattern

public ConsumerTopicConfig.ConsumerTopicConfigBuilder inputPattern(Pattern inputPattern)

Returns:

this.

labeledInputPatterns

public ConsumerTopicConfig.ConsumerTopicConfigBuilder labeledInputPatterns(@NonNull
 @NonNull Map<String,Pattern> labeledInputPatterns)

Input patterns that are identified by a label

Returns:

this.

build

public ConsumerTopicConfig build()

toString

public String toString()

Overrides:

toString in class Object