Package org.wso2.carbon.inbound.endpoint.protocol.kafka

Class SimpleKafkaMessageListener

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.kafka.AbstractKafkaMessageListener

org.wso2.carbon.inbound.endpoint.protocol.kafka.SimpleKafkaMessageListener

public class SimpleKafkaMessageListener
extends AbstractKafkaMessageListener

Nested Class Summary

Nested classes/interfaces inherited from class org.wso2.carbon.inbound.endpoint.protocol.kafka.AbstractKafkaMessageListener

AbstractKafkaMessageListener.CONSUMER_TYPE

Field Summary

Fields inherited from class org.wso2.carbon.inbound.endpoint.protocol.kafka.AbstractKafkaMessageListener

consumerConnector, consumerIte, injectHandler, kafkaProperties, log, threadCount, topics

Constructor Summary

Constructors

Constructor	Description
SimpleKafkaMessageListener(Properties kafkaProperties, InjectHandler injectHandler)

Method Summary

Modifier and Type	Method	Description
boolean	createKafkaConsumerConnector()	Create the connection with the zookeeper
static long	getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer, String topic, int partition, long whichTime, String clientName)
boolean	hasNext()	Check ConsumerIterator whether It has next value
void	injectMessageToESB(String name)	Poll the messages from the zookeeper and injected to the sequence
boolean	run()
void	start()	Start to consume the messages from topics

Methods inherited from class org.wso2.carbon.inbound.endpoint.protocol.kafka.AbstractKafkaMessageListener

consumeMultipleTopics, destroy, hasMultipleTopicsToConsume

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleKafkaMessageListener

public SimpleKafkaMessageListener(Properties kafkaProperties,
 InjectHandler injectHandler)
                           throws Exception

Throws:

Exception

Method Details

createKafkaConsumerConnector

public boolean createKafkaConsumerConnector()
                                     throws Exception

Description copied from class: AbstractKafkaMessageListener

Create the connection with the zookeeper

Specified by:

createKafkaConsumerConnector in class AbstractKafkaMessageListener

Throws:

Exception

start

public void start()
           throws Exception

Description copied from class: AbstractKafkaMessageListener

Start to consume the messages from topics

Specified by:

start in class AbstractKafkaMessageListener

Throws:

Exception

injectMessageToESB

public void injectMessageToESB(String name)

Description copied from class: AbstractKafkaMessageListener

Poll the messages from the zookeeper and injected to the sequence

Specified by:

injectMessageToESB in class AbstractKafkaMessageListener

hasNext

public boolean hasNext()

Description copied from class: AbstractKafkaMessageListener

Check ConsumerIterator whether It has next value

Specified by:

hasNext in class AbstractKafkaMessageListener

run

public boolean run()
            throws Exception

Throws:

Exception

getLastOffset

public static long getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
 String topic,
 int partition,
 long whichTime,
 String clientName)