Package com.bakdata.kafka.consumerproducer

Class ConsumerProducerTopicConfig

java.lang.Object

com.bakdata.kafka.consumerproducer.ConsumerProducerTopicConfig

public final class ConsumerProducerTopicConfig
extends Object

Provides topic configuration for a ConsumerProducerApp

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder

Method Summary

Modifier and Type	Method	Description
static ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder	builder()
boolean	equals(Object o)
String	getErrorTopic()
Pattern	getInputPattern()
@NonNull List<String>	getInputTopics()
@NonNull Map<String,Pattern>	getLabeledInputPatterns()	Input patterns that are identified by a label
@NonNull Map<String,List<String>>	getLabeledInputTopics()	Input topics that are identified by a label
@NonNull Map<String,String>	getLabeledOutputTopics()	Output topics that are identified by a label
String	getOutputTopic()
int	hashCode()
ConsumerTopicConfig	toConsumerTopicConfig()	Convert this config to a ConsumerTopicConfig for the consumer part of the app.
ProducerTopicConfig	toProducerTopicConfig()	Convert this config to a ProducerTopicConfig for the producer part of the app.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

toConsumerTopicConfig

public ConsumerTopicConfig toConsumerTopicConfig()

Convert this config to a ConsumerTopicConfig for the consumer part of the app.

Returns:

ConsumerTopicConfig

toProducerTopicConfig

public ProducerTopicConfig toProducerTopicConfig()

Convert this config to a ProducerTopicConfig for the producer part of the app.

Returns:

ProducerTopicConfig

builder

public static ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder 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

getOutputTopic

public String getOutputTopic()

getLabeledOutputTopics

@NonNull
public @NonNull Map<String,String> getLabeledOutputTopics()

Output topics that are identified by a label

getErrorTopic

public String getErrorTopic()

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