io.smallrye.reactive.messaging.kafka.tracing

Class HeaderInjectAdapter

java.lang.Object

io.smallrye.reactive.messaging.kafka.tracing.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>

Field Summary

Fields

Modifier and Type	Field and Description
static HeaderInjectAdapter	SETTER

Constructor Summary

Constructors

Constructor and Description
HeaderInjectAdapter()

Method Summary

Modifier and Type	Method and Description
void	set(org.apache.kafka.common.header.Headers headers, String key, String value)

Methods inherited from class java.lang.Object

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

Field Detail

SETTER

public static final HeaderInjectAdapter SETTER

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>