Package org.eso.ias.command.kafka

Class ReplyKafkaConsumer

java.lang.Object

org.eso.ias.kafkautils.KafkaStringsConsumer

org.eso.ias.kafkautils.SimpleStringConsumer

org.eso.ias.command.kafka.ReplyKafkaConsumer

All Implemented Interfaces:

Runnable, org.apache.kafka.clients.consumer.ConsumerRebalanceListener, KafkaStringsConsumer.StringsConsumer, SimpleStringConsumer.KafkaConsumerListener

public class ReplyKafkaConsumer
extends SimpleStringConsumer
implements SimpleStringConsumer.KafkaConsumerListener

An helper class to easily consume replies from the kafka reply topic. The object must be initialized invoking KafkaStringsConsumer.setUp() before starting to get replies. Once terminated, KafkaStringsConsumer.tearDown() must be invoked.

Nested Class Summary

Nested classes/interfaces inherited from class org.eso.ias.kafkautils.SimpleStringConsumer

SimpleStringConsumer.KafkaConsumerListener

Nested classes/interfaces inherited from class org.eso.ias.kafkautils.KafkaStringsConsumer

KafkaStringsConsumer.StreamPosition, KafkaStringsConsumer.StringsConsumer

Field Summary

Fields inherited from class org.eso.ias.kafkautils.KafkaStringsConsumer

DEFAULT_CONSUMER_READY_TIMEOUT, MIN_CONSUMER_READY_TIMEOUT, topicName, WAIT_CONSUMER_READY_TIMEOUT_PROP_NAME

Constructor Summary

Constructors

Constructor	Description
ReplyKafkaConsumer(String brokers, String replyConsumerId)	Constructor

Method Summary

Modifier and Type	Method	Description
void	startGettingReplies(KafkaStringsConsumer.StreamPosition startReadingFrom, ReplyListener listener)	Start getting events from the repluy topic
void	stringEventReceived(String event)	A string has bene received from the reply topic

Methods inherited from class org.eso.ias.kafkautils.SimpleStringConsumer

getNumOfProcessedStrings, startGettingStrings, stringsReceived

Methods inherited from class org.eso.ias.kafkautils.KafkaStringsConsumer

getNumOfProcessedRecords, isReady, onPartitionsAssigned, onPartitionsLost, onPartitionsRevoked, run, seekTo, setUp, setUp, startGettingEvents, tearDown, waitUntilConsumerReady

Methods inherited from class java.lang.Object

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

Constructor Details

ReplyKafkaConsumer

public ReplyKafkaConsumer(String brokers,
 String replyConsumerId)

Constructor

Parameters:

brokers - Kafka brokers

replyConsumerId - The id of the consumer

Method Details

stringEventReceived

public void stringEventReceived(String event)

A string has bene received from the reply topic

Specified by:

stringEventReceived in interface SimpleStringConsumer.KafkaConsumerListener

Parameters:

event - The string received in the topic

See Also:

• SimpleStringConsumer.KafkaConsumerListener

startGettingReplies

public void startGettingReplies(KafkaStringsConsumer.StreamPosition startReadingFrom,
 ReplyListener listener)
                         throws KafkaUtilsException

Start getting events from the repluy topic

Parameters:

startReadingFrom - Starting position in the kafka partition

listener - The listener of events published in the topic

Throws:

KafkaUtilsException - in case of timeout subscribing to the kafkatopic