public class SimpleKafkaMessageListener extends AbstractKafkaMessageListener
AbstractKafkaMessageListener.CONSUMER_TYPE
consumerConnector, consumerIte, injectHandler, kafkaProperties, log, threadCount, topics
Constructor and Description |
---|
SimpleKafkaMessageListener(Properties kafkaProperties,
InjectHandler injectHandler) |
Modifier and Type | Method and 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
|
consumeMultipleTopics, destroy, hasMultipleTopicsToConsume
public SimpleKafkaMessageListener(Properties kafkaProperties, InjectHandler injectHandler) throws Exception
Exception
public boolean createKafkaConsumerConnector() throws Exception
AbstractKafkaMessageListener
createKafkaConsumerConnector
in class AbstractKafkaMessageListener
Exception
public void start() throws Exception
AbstractKafkaMessageListener
start
in class AbstractKafkaMessageListener
Exception
public void injectMessageToESB(String name)
AbstractKafkaMessageListener
injectMessageToESB
in class AbstractKafkaMessageListener
public boolean hasNext()
AbstractKafkaMessageListener
hasNext
in class AbstractKafkaMessageListener
Copyright © 2022 WSO2. All rights reserved.