Package com.networknt.kafka.common

Class KafkaConsumerConfig

java.lang.Object

com.networknt.kafka.common.KafkaConsumerConfig

public class KafkaConsumerConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	CONFIG_NAME

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerConfig()

Method Summary

Modifier and Type	Method	Description
int	getAutoCommitIntervalMs()
String	getAutoOffsetReset()
String	getBootstrapServers()
String	getGroupId()
String	getIsolationLevel()
String	getKeyDeserializer()
String	getValueDeserializer()
boolean	isEnableAutoCommit()
void	setAutoCommitIntervalMs(int autoCommitIntervalMs)
void	setAutoOffsetReset(String autoOffsetReset)
void	setBootstrapServers(String bootstrapServers)
void	setEnableAutoCommit(boolean enableAutoCommit)
void	setGroupId(String groupId)
void	setIsolationLevel(String isolationLevel)
void	setKeyDeserializer(String keyDeserializer)
void	setValueDeserializer(String valueDeserializer)

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_NAME

public static final String CONFIG_NAME

See Also:

Constant Field Values

Constructor Detail

KafkaConsumerConfig

public KafkaConsumerConfig()

Method Detail

getBootstrapServers

public String getBootstrapServers()

setBootstrapServers

public void setBootstrapServers(String bootstrapServers)

getIsolationLevel

public String getIsolationLevel()

setIsolationLevel

public void setIsolationLevel(String isolationLevel)

isEnableAutoCommit

public boolean isEnableAutoCommit()

setEnableAutoCommit

public void setEnableAutoCommit(boolean enableAutoCommit)

getKeyDeserializer

public String getKeyDeserializer()

setKeyDeserializer

public void setKeyDeserializer(String keyDeserializer)

getValueDeserializer

public String getValueDeserializer()

setValueDeserializer

public void setValueDeserializer(String valueDeserializer)

getAutoCommitIntervalMs

public int getAutoCommitIntervalMs()

setAutoCommitIntervalMs

public void setAutoCommitIntervalMs(int autoCommitIntervalMs)

getGroupId

public String getGroupId()

setGroupId

public void setGroupId(String groupId)

getAutoOffsetReset

public String getAutoOffsetReset()

setAutoOffsetReset

public void setAutoOffsetReset(String autoOffsetReset)