Package org.eso.ias.monitor

Class KafkaSinkConnectorConfig

java.lang.Object

org.eso.ias.monitor.KafkaSinkConnectorConfig

public class KafkaSinkConnectorConfig
extends Object

The configuration of kafka sink conenctor to monitor These kind of connectors do not pubish HBs and must be monitored with the REST API provided by kafka

Constructor Summary

Constructors

Constructor	Description
KafkaSinkConnectorConfig()	Empty constructor
KafkaSinkConnectorConfig(String hostName, int port, String id)	Construcotr

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getHostName()
String	getId()
int	getPort()
int	hashCode()
void	setHostName(String hostName)
void	setId(String id)
void	setPort(int port)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

KafkaSinkConnectorConfig

public KafkaSinkConnectorConfig()

Empty constructor

KafkaSinkConnectorConfig

public KafkaSinkConnectorConfig(String hostName,
 int port,
 String id)

Construcotr

Parameters:

hostName - The host name to contact with the REST API

port - The port to query the REST API

id - The ID of the kafka sink connector

Method Details

getHostName

public String getHostName()

setHostName

public void setHostName(String hostName)

getPort

public int getPort()

setPort

public void setPort(int port)

getId

public String getId()

setId

public void setId(String id)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object