io.smallrye.reactive.messaging.kafka.tracing

Class HeaderExtractAdapter

java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static HeaderExtractAdapter	GETTER

Constructor Summary

Constructors

Constructor and Description
HeaderExtractAdapter()

Method Summary

Modifier and Type	Method and Description
String	get(org.apache.kafka.common.header.Headers headers, String key)
Iterable<String>	keys(org.apache.kafka.common.header.Headers headers)

Methods inherited from class java.lang.Object

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

Field Detail

GETTER

public static final HeaderExtractAdapter GETTER

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>