Package com.bakdata.kafka.producer

Class ProducerTopicConfig

java.lang.Object

com.bakdata.kafka.producer.ProducerTopicConfig

public final class ProducerTopicConfig
extends Object

Provides topic configuration for a ProducerApp

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProducerTopicConfig.ProducerTopicConfigBuilder

Method Summary

Modifier and Type	Method	Description
static ProducerTopicConfig.ProducerTopicConfigBuilder	builder()
boolean	equals(Object o)
@NonNull Map<String,String>	getLabeledOutputTopics()	Output topics that are identified by a label
String	getOutputTopic()
String	getOutputTopic(String label)	Get output topic for a specified label
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

getOutputTopic

public String getOutputTopic(String label)

Get output topic for a specified label

Parameters:

label - label of output topic

Returns:

topic name

builder

public static ProducerTopicConfig.ProducerTopicConfigBuilder builder()

getOutputTopic

public String getOutputTopic()

getLabeledOutputTopics

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

Output topics that are identified by a label

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