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>

Field Summary

Fields

Modifier and Type	Field and Description
protected io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient<Data,Req,Resp>	bufferingClient
protected String	endpoint
protected Function<Collection<Data>,Req>	requestConverter
protected io.confluent.telemetry.client.RequestSerializer<Req>	requestSerializer
protected io.confluent.telemetry.client.ResponseDeserializer<Resp>	responseDeserializer

Constructor Summary

Constructors

Constructor and Description
HttpExporter()

Method Summary

Modifier and Type	Method and 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

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

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

routeReady

Field Detail

requestConverter

protected Function<Collection<Data>,Req extends com.google.protobuf.MessageLite> requestConverter

responseDeserializer

protected io.confluent.telemetry.client.ResponseDeserializer<Resp extends com.google.protobuf.MessageLite> responseDeserializer

requestSerializer

protected io.confluent.telemetry.client.RequestSerializer<Req extends com.google.protobuf.MessageLite> requestSerializer

bufferingClient

protected io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite> bufferingClient

endpoint

protected String endpoint

Constructor Detail

HttpExporter

public HttpExporter()

Method Detail

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