Class HeaderInjectAdapter

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

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

      • HeaderInjectAdapter

        public HeaderInjectAdapter()
    • Method Detail

      • set

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