Instrumentation of Kafka Clients : Add custom Attributes Extractor

[adityasc94]

I am using the interceptors provided by Kafka clients instrumentation library in a simple Kafka Producer by following the example in: https://github.com/ppatierno/kafka-opentelemetry/tree/main/kafka-producer

I want send custom attributes to the span.

The KafkaTelemetryBuilder class has a method "addProducerAttributesExtractors" to add extra AttributesExtractor:
opentelemetry-java-instrumentation/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetryBuilder.java

I would like to know if there is a way to use this approach along with the interceptors.

[laurit]

You can copy the interceptor class and modify the way it builds the KafkaTelemetry instance.

[adityasc94]

Hi @laurit, thank you for the feedback. I tried using this approach, but I am not able to call the "buildAndInjectSpan" method of KafkaTelemetry instance from my custom interceptor as the method is having "default" scope which restricts access outside the package.

opentelemetry-java-instrumentation/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetry.java

Line 177 in e8464f6

<K, V> void buildAndInjectSpan(ProducerRecord<K, V> record, String clientId) {