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

Class HttpExporterConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.telemetry.events.exporter.ExporterConfig
io.confluent.telemetry.events.exporter.http.HttpExporterConfig
public class HttpExporterConfig extends ExporterConfig
Configuration for the HttpExporter. Note that we maintain the defaults in the `telemetry-client` library, so many of the defaults in this class are null.

  • Field Details

  • Constructor Details

    • HttpExporterConfig

      public HttpExporterConfig(Map<String,?> originals)

  • Method Details

    • main

      public static void main(String[] args)

    • equals

      public boolean equals(Object o)
      Equality and hash code based on all fields that determine HTTP client identity, including initial credentials and proxy settings. Used by HttpClientFactory to share clients across exporters with identical configs.

      Credentials and proxy are included so that exporters with different credentials never share a client, avoiding credential supplier mixing. Per-exporter configs (filtering) are excluded as they do not affect client construction.

      Overrides:
      equals in class org.apache.kafka.common.config.AbstractConfig

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class org.apache.kafka.common.config.AbstractConfig

    • getCredentials

      public io.confluent.telemetry.client.Credentials getCredentials()

    • getProxyConfig

      public io.confluent.telemetry.client.ProxyConfig getProxyConfig()

    • getCompressionAlgorithm

      public io.confluent.telemetry.client.CompressionAlgorithm getCompressionAlgorithm(String key)
      Get the compression algorithm. If the algorithm is unknown, this returns null.

    • getClientBuilder

      public <Req extends com.google.protobuf.MessageLite, Resp extends com.google.protobuf.MessageLite> io.confluent.telemetry.client.TelemetryHttpClient.Builder<Req,Resp> getClientBuilder()

    • getBufferingAsyncClientBuilder

      public <Data, Req extends com.google.protobuf.MessageLite, Res extends com.google.protobuf.MessageLite> io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<Data,Req,Res> getBufferingAsyncClientBuilder()

    • canEmitTelemetry

      public Boolean canEmitTelemetry()

    • isFilteringEnabled

      public boolean isFilteringEnabled()

    • getAllowedRoutes

      public Set<String> getAllowedRoutes()