public class HttpExporter<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite> extends java.lang.Object implements Exporter<Data>
Modifier and Type | Field and Description |
---|---|
protected io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient<Data,Req,Resp> |
bufferingClient |
boolean |
canEmitTelemetry |
protected java.lang.String |
endpoint |
protected java.util.function.Function<java.util.Collection<Data>,Req> |
requestConverter |
protected java.util.function.Function<java.nio.ByteBuffer,Resp> |
responseDeserializer |
Constructor and Description |
---|
HttpExporter() |
Modifier and Type | Method and Description |
---|---|
void |
bufferingClient(io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient<Data,Req,Resp> bufferingClient) |
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
void |
emit(Data data)
Filter and transform the events as appropriate and send to the specified destination.
|
java.util.Set<java.lang.String> |
reconfigurableConfigs() |
void |
reconfigure(java.util.Map<java.lang.String,?> configs) |
void |
validateReconfiguration(java.util.Map<java.lang.String,?> configs) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
routeReady
protected java.util.function.Function<java.util.Collection<Data>,Req extends com.google.protobuf.MessageLite> requestConverter
protected java.util.function.Function<java.nio.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
public volatile boolean canEmitTelemetry
protected java.lang.String endpoint
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void emit(Data data) throws java.lang.RuntimeException
Exporter
public void close()
close
in interface java.lang.AutoCloseable
public void reconfigure(java.util.Map<java.lang.String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
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