public class EventKafkaExporter extends KafkaExporter<io.confluent.telemetry.api.events.Event>
Constructor and Description |
---|
EventKafkaExporter() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
close, emit, producer, reconfigurableConfigs, reconfigure, validateReconfiguration
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
routeReady
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
configure
in class KafkaExporter<io.confluent.telemetry.api.events.Event>