Package org.eso.ias.kafkautils

package org.eso.ias.kafkautils

A collection of Kafka utilities.

Author:

acaproni

Class	Description
FilteredKafkaIasiosConsumer	FilteredKafkaIasiosConsumer allows to set a custom filter on top of the Kafka consumer.
FilteredKafkaIasiosConsumer.FilterIasValue	The filter to apply to IASValues
KafkaHelper	A helper class providing useful methods and constants for Kafka
KafkaIasiosConsumer	Extends SimpleKafkaIasiosConsumer providing filtering by IDs and types.
KafkaIasiosProducer	KafkaIasioProducer writes IASValue in the kafka topic by delegating to SimpleStringProducer
KafkaStringsConsumer	A generic kafka consumer that forwards all the strings received in each message to the listener.
KafkaStringsConsumer.StreamPosition	The start position when connecting to a kafka topic for reading strings
KafkaStringsConsumer.StringsConsumer	The interface for the listener of strings
KafkaUtilsException	Exception retunrd by classes in KafkaUtils module
SimpleKafkaIasiosConsumer	KafkaIasiosConsumer gets the strings from the passed IASIO kafka topic from the KafkaStringsConsumer and forwards the IASIOs to the listener.
SimpleKafkaIasiosConsumer.IasioListener	The listener to be notified of Iasios read from the kafka topic.
SimpleStringConsumer	/** Generic Kafka consumer to get strings from a kafka topic.
SimpleStringConsumer.KafkaConsumerListener	The listener to be notified of strings read from the kafka topic.
SimpleStringProducer	SimpleStringProducer pushes strings on a Kafka topic.