Package io.confluent.telemetry.events.exporter.http

Class HttpExporter<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite>

java.lang.Object

io.confluent.telemetry.events.exporter.http.HttpExporter<Data,Req,Resp>

All Implemented Interfaces:

Exporter<Data>, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.Reconfigurable

Direct Known Subclasses:

EventHttpExporter

public class HttpExporter<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite>
extends Object
implements Exporter<Data>

Constructor Summary

Constructors

Constructor	Description
HttpExporter()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
CompletableFuture<Boolean>	emit(Data data)	Filter and transform the events as appropriate and send to the specified destination.
Set<String>	reconfigurableConfigs()
void	reconfigure(Map<String,?> configs)
void	validateReconfiguration(Map<String,?> configs)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.telemetry.events.exporter.Exporter

routeReady

Constructor Details

HttpExporter

public HttpExporter()

Method Details

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

emit

public CompletableFuture<Boolean> emit(Data data)

Description copied from interface: Exporter

Filter and transform the events as appropriate and send to the specified destination. This method takes care of batching, serialization and retries.

Specified by:

emit in interface Exporter<Data>

Returns:

A CompletableFuture object with a Boolean value, indicates if event has been sent successfully

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

reconfigure

public void reconfigure(Map<String,?> configs)

Specified by:

reconfigure in interface org.apache.kafka.common.Reconfigurable

reconfigurableConfigs

public Set<String> reconfigurableConfigs()

Specified by:

reconfigurableConfigs in interface org.apache.kafka.common.Reconfigurable

validateReconfiguration

public void validateReconfiguration(Map<String,?> configs)
                             throws org.apache.kafka.common.config.ConfigException

Specified by:

validateReconfiguration in interface org.apache.kafka.common.Reconfigurable

Throws:

org.apache.kafka.common.config.ConfigException