Package org.eso.ias.kafkautils

Class FilteredKafkaIasiosConsumer

java.lang.Object

org.eso.ias.kafkautils.SimpleKafkaIasiosConsumer

org.eso.ias.kafkautils.FilteredKafkaIasiosConsumer

All Implemented Interfaces:

KafkaStringsConsumer.StringsConsumer

public class FilteredKafkaIasiosConsumer
extends SimpleKafkaIasiosConsumer

FilteredKafkaIasiosConsumer allows to set a custom filter on top of the Kafka consumer. The filter implements the FilterIaValue interface.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FilteredKafkaIasiosConsumer.FilterIasValue	The filter to apply to IASValues

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

SimpleKafkaIasiosConsumer.IasioListener

Field Summary

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

seekIfOlderThan, SeekIfOlderThanProName

Constructor Summary

Constructors

Constructor	Description
FilteredKafkaIasiosConsumer(String servers, String topicName, String consumerID, FilteredKafkaIasiosConsumer.FilterIasValue filter)	Constructor

Method Summary

Modifier and Type	Method	Description
protected boolean	accept(IASValue<?> iasio)	Accepts or rejects a IASValue against the filters, if set

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

getNumOfProcessedRecords, setUp, setUp, startGettingEvents, stringsReceived, tearDown

Methods inherited from class java.lang.Object

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

Constructor Details

FilteredKafkaIasiosConsumer

public FilteredKafkaIasiosConsumer(String servers,
 String topicName,
 String consumerID,
 FilteredKafkaIasiosConsumer.FilterIasValue filter)

Constructor

Parameters:

servers - The kafka servers to connect to

topicName - The name of the topic to get events from

consumerID - the ID of the consumer

filter - The filter to apply to accept or discard IASValues

Method Details

accept

protected boolean accept(IASValue<?> iasio)

Accepts or rejects a IASValue against the filters, if set

Overrides:

accept in class SimpleKafkaIasiosConsumer

Parameters:

iasio - The IASValue to accept or discard

Returns:

true if the value is accpted; false otherwise