Package org.eso.ias.converter

Class ConverterKafkaStream

java.lang.Object

org.eso.ias.converter.ConverterStream

org.eso.ias.converter.ConverterKafkaStream

public class ConverterKafkaStream
extends ConverterStream

The kafka stream used by the converter to get JSON strings from the plugins and sends JSON strings to the core of the IAS.

The list of kafka servers to connect to and the names of the input and output topics can be passed by means of java properties or programmatically.

Author:

acaproni

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_CONSUMER_GROUPID	The default groupid of the Kafka consumer
static final String	IASCORE_TOPIC_NAME_PROP_NAME	The name of the java property to get the name of the topic where plugins push values
static final String	KAFKA_CONSUMER_GROUP_ID_PROP_NAME	The name of the property to customize the group id of the consumer
static final String	KAFKA_SERVERS_PROP_NAME	The name of the property to pass the kafka servers to connect to

Fields inherited from class org.eso.ias.converter.ConverterStream

converterID, mapper

Constructor Summary

Constructors

Constructor	Description
ConverterKafkaStream(String converterID, String servers, String pluginTopicName, String iasCoreTopicName)	Constructor
ConverterKafkaStream(String converterID, Optional<String> kafkaBrokers, Properties props)	The constructor takes the names of the topics for the streaming from the passed properties or falls back to the defaults.

Method Summary

Modifier and Type	Method	Description
void	init()	Initialize the stream
protected void	startStreaming()	Start streaming data from the kafka input topic to the kafka output topic
protected void	stopStreaming()	Stop streaming data

Methods inherited from class org.eso.ias.converter.ConverterStream

initialize, start, stop

Methods inherited from class java.lang.Object

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

Field Details

IASCORE_TOPIC_NAME_PROP_NAME

public static final String IASCORE_TOPIC_NAME_PROP_NAME

The name of the java property to get the name of the topic where plugins push values

See Also:

• Constant Field Values

KAFKA_SERVERS_PROP_NAME

public static final String KAFKA_SERVERS_PROP_NAME

The name of the property to pass the kafka servers to connect to

See Also:

• Constant Field Values

KAFKA_CONSUMER_GROUP_ID_PROP_NAME

public static final String KAFKA_CONSUMER_GROUP_ID_PROP_NAME

The name of the property to customize the group id of the consumer

See Also:

• Constant Field Values

DEFAULT_CONSUMER_GROUPID

public static final String DEFAULT_CONSUMER_GROUPID

The default groupid of the Kafka consumer

See Also:

• Constant Field Values

Constructor Details

ConverterKafkaStream

public ConverterKafkaStream(String converterID,
 Optional<String> kafkaBrokers,
 Properties props)

The constructor takes the names of the topics for the streaming from the passed properties or falls back to the defaults. The constructor takes the string to connect to kafka brokers from the parameters of from the passed properties. The property overrides the value passed in kafkaBrokers. If the parameter is empty and no property is defined, it falls to default kafka broker URL defined in KafkaHelper.DEFAULT_BOOTSTRAP_BROKERS.

Parameters:

converterID - The ID of the converter

kafkaBrokers - The URL to connect to kafka broker(s) read from the CDB

props - the properties to get kafka serves and topic anmes

ConverterKafkaStream

public ConverterKafkaStream(String converterID,
 String servers,
 String pluginTopicName,
 String iasCoreTopicName)

Constructor

Parameters:

converterID - The ID of the converter

servers - The kafka servers to connect to

pluginTopicName - The name of the topic to get monitor points from plugins

iasCoreTopicName - The name of the topic to send values to the core of the IAS

Method Details

init

public void init()

Initialize the stream

Specified by:

init in class ConverterStream

startStreaming

protected void startStreaming()
                       throws ConverterStreamException

Start streaming data from the kafka input topic to the kafka output topic

Specified by:

startStreaming in class ConverterStream

Throws:

ConverterStreamException - in case of error starting

See Also:

• ConverterStream.start()

stopStreaming

protected void stopStreaming()
                      throws ConverterStreamException

Stop streaming data

Specified by:

stopStreaming in class ConverterStream

Throws:

ConverterStreamException - in case of error stopping

See Also:

• ConverterStream.stop()