Package com.bakdata.kafka.streams

Class StreamsTopicConfig.StreamsTopicConfigBuilder

java.lang.Object

com.bakdata.kafka.streams.StreamsTopicConfig.StreamsTopicConfigBuilder

Enclosing class:

StreamsTopicConfig

public static class StreamsTopicConfig.StreamsTopicConfigBuilder
extends Object

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

inputTopics

public StreamsTopicConfig.StreamsTopicConfigBuilder inputTopics(@NonNull
 @NonNull List<String> inputTopics)

Returns:

this.

labeledInputTopics

public StreamsTopicConfig.StreamsTopicConfigBuilder labeledInputTopics(@NonNull
 @NonNull Map<String,List<String>> labeledInputTopics)

Input topics that are identified by a label

Returns:

this.

inputPattern

public StreamsTopicConfig.StreamsTopicConfigBuilder inputPattern(Pattern inputPattern)

Returns:

this.

labeledInputPatterns

public StreamsTopicConfig.StreamsTopicConfigBuilder labeledInputPatterns(@NonNull
 @NonNull Map<String,Pattern> labeledInputPatterns)

Input patterns that are identified by a label

Returns:

this.

outputTopic

public StreamsTopicConfig.StreamsTopicConfigBuilder outputTopic(String outputTopic)

Returns:

this.

labeledOutputTopics

public StreamsTopicConfig.StreamsTopicConfigBuilder labeledOutputTopics(@NonNull
 @NonNull Map<String,String> labeledOutputTopics)

Output topics that are identified by a label

Returns:

this.

errorTopic

public StreamsTopicConfig.StreamsTopicConfigBuilder errorTopic(String errorTopic)

Returns:

this.

build

public StreamsTopicConfig build()

toString

public String toString()

Overrides:

toString in class Object