KafkaSubscriber

org.eso.ias.dasu.subscriber.KafkaSubscriber

See theKafkaSubscriber companion object

class KafkaSubscriber(val consumerId: String, kafkaConsumer: KafkaIasiosConsumer, val props: Properties) extends IasioListener, InputSubscriber

Read IASValues from the kafka queue and forward them to the listener for processing.

KafkaSubscriber delegates to KafkaIasiosConsumer and it is mostly a convenience class to use the java KafkaIasiosConsumer class from scala

Filtering by ID, passed in startSuscriber, is supported by delegating to the KafkaIasiosConsumer.

Value parameters

Companion: object
Graph
Supertypes: trait InputSubscriber

trait IasioListener

class Object

trait Matchable

class Any

CleanUp and release the resources

Forward the IASValue received from the kafka topic to the listener

Initialize the subscriber

Start to get events and forward them to the listener.

IASIOs whose ID is not in the acceptedInputs set are discarded.

acceptedInputs: the IDs of the inputs accepted by the listener (if empty accepts all the IasValues)
listener: the listener of events

In this article

Generated with