Package com.bakdata.kafka.mixin

Class InputOptions

java.lang.Object

com.bakdata.kafka.mixin.InputOptions

public class InputOptions
extends Object

Shared CLI options to configure Kafka applications that consume input data.

Constructor Summary

Constructors

Constructor	Description
InputOptions()

Method Summary

Modifier and Type	Method	Description
Pattern	getInputPattern()
List<String>	getInputTopics()
Map<String,Pattern>	getLabeledInputPatterns()
Map<String,List<String>>	getLabeledInputTopics()
void	setInputPattern(Pattern inputPattern)
void	setInputTopics(List<String> inputTopics)
void	setLabeledInputPatterns(Map<String,Pattern> labeledInputPatterns)
void	setLabeledInputTopics(Map<String,List<String>> labeledInputTopics)

Methods inherited from class java.lang.Object

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

Constructor Details

InputOptions

public InputOptions()

Method Details

getInputTopics

public List<String> getInputTopics()

getInputPattern

public Pattern getInputPattern()

getLabeledInputTopics

public Map<String,List<String>> getLabeledInputTopics()

getLabeledInputPatterns

public Map<String,Pattern> getLabeledInputPatterns()

setInputTopics

public void setInputTopics(List<String> inputTopics)

setInputPattern

public void setInputPattern(Pattern inputPattern)

setLabeledInputTopics

public void setLabeledInputTopics(Map<String,List<String>> labeledInputTopics)

setLabeledInputPatterns

public void setLabeledInputPatterns(Map<String,Pattern> labeledInputPatterns)