Package io.confluent.telemetry.provider

Class KafkaRestProvider

java.lang.Object
io.confluent.telemetry.provider.KafkaRestProvider
All Implemented Interfaces:
Provider, org.apache.kafka.common.Configurable
public class KafkaRestProvider extends Object implements Provider

  • Field Details

  • Constructor Details

    • KafkaRestProvider

      public KafkaRestProvider()

  • Method Details

    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable

    • validate

      public boolean validate(org.apache.kafka.common.metrics.MetricsContext metricsContext, Map<String,?> config)
      Description copied from interface: Provider
      Validate that all the data required for generating correct metrics is present. The provider will be disabled if validation fails.
      Specified by:
      validate in interface Provider
      Parameters:
      metricsContext - MetricsContext
      Returns:
      false if all the data required for generating correct metrics is missing, true otherwise.

    • contextChange

      public void contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
      Description copied from interface: Provider
      Sets the metrics labels for the service or library exposing metrics. This will be called before MetricsReporter.init(List) and may be called anytime after that.
      Specified by:
      contextChange in interface Provider
      Parameters:
      metricsContext - MetricsContext

    • resource

      public io.opentelemetry.proto.resource.v1.Resource resource()
      Description copied from interface: Provider
      The resource for this provider.
      Specified by:
      resource in interface Provider
      Returns:
      A fully formed Resource will all the tags.

    • domain

      public String domain()
      Description copied from interface: Provider
      Domain of the active provider. This is used by other parts of the reporter.
      Specified by:
      domain in interface Provider
      Returns:
      Domain in string format.

    • extraCollectors

      public List<MetricsCollector> extraCollectors(Context ctx)
      Description copied from interface: Provider
      The collector for Kafka Metrics library is enabled by default. If you need any more, add them here.
      Specified by:
      extraCollectors in interface Provider
      Parameters:
      ctx - Context
      Returns:
      List of extra collectors

    • metricsIncludeRegexDefault

      public List<String> metricsIncludeRegexDefault()
      Description copied from interface: Provider
      The metrics include regular expression list used as a default value for this provider. This list will be joined as following '.*.*|.*.*' to form a union.
      Specified by:
      metricsIncludeRegexDefault in interface Provider
      Returns:
      a list of regular expressions to match metric names