Package com.networknt.kafka.common
Class KafkaStreamsConfig
- java.lang.Object
-
- com.networknt.kafka.common.KafkaStreamsConfig
-
public class KafkaStreamsConfig extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static StringCONFIG_NAME
-
Constructor Summary
Constructors Constructor Description KafkaStreamsConfig()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetApplicationId()StringgetBootstrapServers()StringgetProcessingGuarantee()intgetReplicationFactor()booleanisCleanUp()voidsetApplicationId(String applicationId)voidsetBootstrapServers(String bootstrapServers)voidsetCleanUp(boolean cleanUp)voidsetProcessingGuarantee(String processingGuarantee)voidsetReplicationFactor(int replicationFactor)
-
-
-
Field Detail
-
CONFIG_NAME
public static final String CONFIG_NAME
- See Also:
- Constant Field Values
-
-
Method Detail
-
getApplicationId
public String getApplicationId()
-
setApplicationId
public void setApplicationId(String applicationId)
-
getBootstrapServers
public String getBootstrapServers()
-
setBootstrapServers
public void setBootstrapServers(String bootstrapServers)
-
getProcessingGuarantee
public String getProcessingGuarantee()
-
setProcessingGuarantee
public void setProcessingGuarantee(String processingGuarantee)
-
getReplicationFactor
public int getReplicationFactor()
-
setReplicationFactor
public void setReplicationFactor(int replicationFactor)
-
isCleanUp
public boolean isCleanUp()
-
setCleanUp
public void setCleanUp(boolean cleanUp)
-
-