com.bluejeans.common.utils.kafka

Class SimpleKafkaConsumer<K,V>

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

public class SimpleKafkaConsumer<K,V>
extends Thread

Kafka String based consumer

Author:

Dinesh Ilindra

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleKafkaConsumer.Status

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SimpleKafkaConsumer()

Method Summary

Modifier and Type	Method and Description
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()
AtomicBoolean	getUpdateNeeded()
org.apache.kafka.common.serialization.Deserializer<V>	getValueDeserializer()
void	init()
boolean	isEnableAutoCommit()
boolean	isSpecificPartitions()
Set<String>	listTopicNames() List all topic names
void	preInit()
void	reassignTopic(String topic) Re assign the topic
void	run()
void	setAutoCommitIntervalMillis(int autoCommitIntervalMillis)
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()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleKafkaConsumer

public SimpleKafkaConsumer()

Method Detail

init

@PostConstruct
public void init()

preInit

public void preInit()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

consumeFromPartition

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

shutdown

@PreDestroy
public void shutdown()

reassignTopic

public void reassignTopic(String topic)

Re assign the topic

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

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

getUpdateNeeded

public AtomicBoolean getUpdateNeeded()

Returns:

the updateNeeded

getStatusCounter

public EnumCounter<SimpleKafkaConsumer.Status> getStatusCounter()

Returns:

the statusCounter