Class OpenTelemetryMetricsSerde

java.lang.Object
io.confluent.telemetry.serde.OpenTelemetryMetricsSerde
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData>, org.apache.kafka.common.serialization.Serde<io.opentelemetry.proto.metrics.v1.MetricsData>, org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData>
public class OpenTelemetryMetricsSerde extends Object implements org.apache.kafka.common.serialization.Serde<io.opentelemetry.proto.metrics.v1.MetricsData>, org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData>, org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData>

  • Constructor Summary

    Constructors
    Constructor
    Description
    OpenTelemetryMetricsSerde()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    void
    configure(Map<String,?> configs, boolean isKey)
     
    io.opentelemetry.proto.metrics.v1.MetricsData
    deserialize(String topic, byte[] data)
     
    org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData>
    deserializer()
     
    byte[]
    serialize(String topic, io.opentelemetry.proto.metrics.v1.MetricsData data)
     
    org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData>
    serializer()
     

    Methods inherited from class Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

    deserialize, deserialize

    Methods inherited from interface org.apache.kafka.common.serialization.Serializer

    serialize

  • Constructor Details

    • OpenTelemetryMetricsSerde

      public OpenTelemetryMetricsSerde()

  • Method Details

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData>
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Serde<io.opentelemetry.proto.metrics.v1.MetricsData>
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData>

    • deserialize

      public io.opentelemetry.proto.metrics.v1.MetricsData deserialize(String topic, byte[] data)
      Specified by:
      deserialize in interface org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData>

    • serialize

      public byte[] serialize(String topic, io.opentelemetry.proto.metrics.v1.MetricsData data)
      Specified by:
      serialize in interface org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData>

    • serializer

      public org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData> serializer()
      Specified by:
      serializer in interface org.apache.kafka.common.serialization.Serde<io.opentelemetry.proto.metrics.v1.MetricsData>

    • deserializer

      public org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData> deserializer()
      Specified by:
      deserializer in interface org.apache.kafka.common.serialization.Serde<io.opentelemetry.proto.metrics.v1.MetricsData>

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.common.serialization.Deserializer<io.opentelemetry.proto.metrics.v1.MetricsData>
      Specified by:
      close in interface org.apache.kafka.common.serialization.Serde<io.opentelemetry.proto.metrics.v1.MetricsData>
      Specified by:
      close in interface org.apache.kafka.common.serialization.Serializer<io.opentelemetry.proto.metrics.v1.MetricsData>