Class HeaderExtractAdapter

  • All Implemented Interfaces:
    io.opentelemetry.context.propagation.TextMapGetter<org.apache.kafka.common.header.Headers>

    public class HeaderExtractAdapter
    extends Object
    implements io.opentelemetry.context.propagation.TextMapGetter<org.apache.kafka.common.header.Headers>
    • Constructor Detail

      • HeaderExtractAdapter

        public HeaderExtractAdapter()
    • Method Detail

      • keys

        public Iterable<String> keys​(org.apache.kafka.common.header.Headers headers)
        Specified by:
        keys in interface io.opentelemetry.context.propagation.TextMapGetter<org.apache.kafka.common.header.Headers>
      • get

        public String get​(org.apache.kafka.common.header.Headers headers,
                          String key)
        Specified by:
        get in interface io.opentelemetry.context.propagation.TextMapGetter<org.apache.kafka.common.header.Headers>