io.druid.emitter.kafka

Class KafkaEmitterConfig

java.lang.Object

io.druid.emitter.kafka.KafkaEmitterConfig

public class KafkaEmitterConfig
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaEmitterConfig(String bootstrapServers, String metricTopic, String alertTopic, String clusterName, Map<String,String> kafkaProducerConfig)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getAlertTopic()
String	getBootstrapServers()
String	getClusterName()
Map<String,String>	getKafkaProducerConfig()
String	getMetricTopic()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEmitterConfig

public KafkaEmitterConfig(String bootstrapServers,
                          String metricTopic,
                          String alertTopic,
                          String clusterName,
                          @Nullable
                          Map<String,String> kafkaProducerConfig)

Method Detail

getBootstrapServers

public String getBootstrapServers()

getMetricTopic

public String getMetricTopic()

getAlertTopic

public String getAlertTopic()

getClusterName

public String getClusterName()

getKafkaProducerConfig

public Map<String,String> getKafkaProducerConfig()

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