public class HttpExporter<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite> extends Object implements Exporter<Data>
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 and Description |
---|
HttpExporter() |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
routeReady
protected Function<Collection<Data>,Req extends com.google.protobuf.MessageLite> requestConverter
protected io.confluent.telemetry.client.ResponseDeserializer<Resp extends com.google.protobuf.MessageLite> responseDeserializer
protected io.confluent.telemetry.client.RequestSerializer<Req extends com.google.protobuf.MessageLite> requestSerializer
protected io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite> bufferingClient
protected String endpoint
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public CompletableFuture<Boolean> emit(Data data)
Exporter
public void close() throws IOException
close
in interface AutoCloseable
IOException
public void reconfigure(Map<String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable