Constructor and Description |
---|
KafkaExporter() |
Modifier and Type | Method and Description |
---|---|
void |
append(io.cloudevents.CloudEvent event)
Filter and transform the events as appropriate and send to the specified destination
|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
EventLoggerConfig |
eventLogConfig() |
java.time.Instant |
lastMetadataRefresh() |
java.util.Set<java.lang.String> |
reconfigurableConfigs() |
void |
reconfigure(java.util.Map<java.lang.String,?> configs) |
boolean |
routeReady(io.cloudevents.CloudEvent event)
Checks if a topic is ready.
|
void |
validateReconfiguration(java.util.Map<java.lang.String,?> configs) |
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void append(io.cloudevents.CloudEvent event) throws java.lang.RuntimeException
Exporter
public boolean routeReady(io.cloudevents.CloudEvent event)
Exporter
routeReady
in interface Exporter
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception
public java.util.Set<java.lang.String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(java.util.Map<java.lang.String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
public void reconfigure(java.util.Map<java.lang.String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public java.time.Instant lastMetadataRefresh()
public EventLoggerConfig eventLogConfig()