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 Function<ByteBuffer,Resp> |
responseDeserializer |
Constructor and Description |
---|
HttpExporter() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> configs) |
void |
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 Function<ByteBuffer,Resp extends com.google.protobuf.MessageLite> responseDeserializer
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 void emit(Data data) throws RuntimeException
Exporter
emit
in interface Exporter<Data>
RuntimeException
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