com.bluejeans.common.utils.kafka

Class SimpleKafkaConsumer<K,V>

java.lang.Object

com.bluejeans.common.utils.kafka.SimpleKafkaConsumer<K,V>

public class SimpleKafkaConsumer<K,V>
extends Object

Kafka String based consumer

Author:

Dinesh Ilindra

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleKafkaConsumer.Status

Constructor Summary

Constructors

Constructor and Description
SimpleKafkaConsumer()

Method Summary

Modifier and Type	Method and Description
void	addTopicPartition(String topicPartition) Add a topic-partition
void	consumeFromPartition(String server, String partitionString, KafkaRecordProcessor<K,V>... kafkaRecordProcessors)
int	getAutoCommitIntervalMillis()
org.apache.kafka.clients.consumer.KafkaConsumer<K,V>	getConsumer()
Map<String,Object>	getExtraProps()
String	getGroupId()
org.apache.kafka.common.serialization.Deserializer<K>	getKeyDeserializer()
int	getPollTimeout()
List<KafkaRecordProcessor<K,V>>	getRecordProcessors()
AtomicBoolean	getRunning()
String	getServer()
int	getSessionTimeoutMillis()
EnumCounter<SimpleKafkaConsumer.Status>	getStatusCounter()
String	getTopic()
org.apache.kafka.common.serialization.Deserializer<V>	getValueDeserializer()
void	init()
boolean	isCommitSyncEnabled()
boolean	isEnableAutoCommit()
boolean	isSpecificPartitions()
Set<String>	listTopicNames() List all topic names
void	preInit()
void	reassignTopic(String topic) Re assign the topics
void	removeTopicPartition(String topicPartition) Add a topic-partition
void	setAutoCommitIntervalMillis(int autoCommitIntervalMillis)
void	setCommitSyncEnabled(boolean commitSyncEnabled)
void	setEnableAutoCommit(boolean enableAutoCommit)
void	setExtraProps(Map<String,Object> extraProps)
void	setGroupId(String groupId)
void	setKeyDeserializer(org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)
void	setPollTimeout(int pollTimeout)
void	setRecordProcessors(List<KafkaRecordProcessor<K,V>> recordProcessors)
void	setServer(String server)
void	setSessionTimeoutMillis(int sessionTimeoutMillis)
void	setSpecificPartitions(boolean specificPartitions)
void	setTopic(String topic)
void	setValueDeserializer(org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
void	shutdown()
void	start()
void	update()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleKafkaConsumer

public SimpleKafkaConsumer()

Method Detail

init

@PostConstruct
public void init()

start

public void start()

preInit

public void preInit()

update

public void update()

consumeFromPartition

public void consumeFromPartition(String server,
                                 String partitionString,
                                 KafkaRecordProcessor<K,V>... kafkaRecordProcessors)

shutdown

@PreDestroy
public void shutdown()

addTopicPartition

public void addTopicPartition(String topicPartition)

Add a topic-partition

removeTopicPartition

public void removeTopicPartition(String topicPartition)

Add a topic-partition

reassignTopic

public void reassignTopic(String topic)

Re assign the topics

listTopicNames

public Set<String> listTopicNames()

List all topic names

getServer

public String getServer()

Returns:

the server

setServer

public void setServer(String server)

Parameters:

server - the server to set

getGroupId

public String getGroupId()

Returns:

the groupId

setGroupId

public void setGroupId(String groupId)

Parameters:

groupId - the groupId to set

isEnableAutoCommit

public boolean isEnableAutoCommit()

Returns:

the enableAutoCommit

setEnableAutoCommit

public void setEnableAutoCommit(boolean enableAutoCommit)

Parameters:

enableAutoCommit - the enableAutoCommit to set

isCommitSyncEnabled

public boolean isCommitSyncEnabled()

Returns:

the commitSyncEnabled

setCommitSyncEnabled

public void setCommitSyncEnabled(boolean commitSyncEnabled)

Parameters:

commitSyncEnabled - the commitSyncEnabled to set

getAutoCommitIntervalMillis

public int getAutoCommitIntervalMillis()

Returns:

the autoCommitIntervalMillis

setAutoCommitIntervalMillis

public void setAutoCommitIntervalMillis(int autoCommitIntervalMillis)

Parameters:

autoCommitIntervalMillis - the autoCommitIntervalMillis to set

getSessionTimeoutMillis

public int getSessionTimeoutMillis()

Returns:

the sessionTimeoutMillis

setSessionTimeoutMillis

public void setSessionTimeoutMillis(int sessionTimeoutMillis)

Parameters:

sessionTimeoutMillis - the sessionTimeoutMillis to set

getKeyDeserializer

public org.apache.kafka.common.serialization.Deserializer<K> getKeyDeserializer()

Returns:

the keyDeserializer

setKeyDeserializer

public void setKeyDeserializer(org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)

Parameters:

keyDeserializer - the keyDeserializer to set

getValueDeserializer

public org.apache.kafka.common.serialization.Deserializer<V> getValueDeserializer()

Returns:

the valueDeserializer

setValueDeserializer

public void setValueDeserializer(org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)

Parameters:

valueDeserializer - the valueDeserializer to set

getTopic

public String getTopic()

Returns:

the topic

setTopic

public void setTopic(String topic)

Parameters:

topic - the topic to set

isSpecificPartitions

public boolean isSpecificPartitions()

Returns:

the specificPartitions

setSpecificPartitions

public void setSpecificPartitions(boolean specificPartitions)

Parameters:

specificPartitions - the specificPartitions to set

getPollTimeout

public int getPollTimeout()

Returns:

the pollTimeout

setPollTimeout

public void setPollTimeout(int pollTimeout)

Parameters:

pollTimeout - the pollTimeout to set

getConsumer

public org.apache.kafka.clients.consumer.KafkaConsumer<K,V> getConsumer()

Returns:

the consumer

getRunning

public AtomicBoolean getRunning()

Returns:

the running

getRecordProcessors

public List<KafkaRecordProcessor<K,V>> getRecordProcessors()

Returns:

the recordProcessors

setRecordProcessors

public void setRecordProcessors(List<KafkaRecordProcessor<K,V>> recordProcessors)

Parameters:

recordProcessors - the recordProcessors to set

getExtraProps

public Map<String,Object> getExtraProps()

Returns:

the extraProps

setExtraProps

public void setExtraProps(Map<String,Object> extraProps)

Parameters:

extraProps - the extraProps to set

getStatusCounter

public EnumCounter<SimpleKafkaConsumer.Status> getStatusCounter()

Returns:

the statusCounter