Merge pull request #2677 from brunobat/bump-otel-instr-2-5

Bump OTel instrumentation to 2.5.0
smallrye · Jul 12, 2024 · 30852c8 · 30852c8
2 parents f6588ed + 7375421
commit 30852c8
Show file tree

Hide file tree

Showing 15 changed files with 244 additions and 65 deletions.
diff --git a/documentation/src/main/java/connectors/tracing/MyAttributesExtractor.java b/documentation/src/main/java/connectors/tracing/MyAttributesExtractor.java
@@ -1,9 +1,12 @@
 package connectors.tracing;
 
+import java.util.Collections;
+import java.util.List;
+
 import io.opentelemetry.api.common.AttributesBuilder;
 import io.opentelemetry.context.Context;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
 import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
 
 public class MyAttributesExtractor implements AttributesExtractor<MyTrace, Void> {
     private final MessagingAttributesGetter<MyTrace, Void> messagingAttributesGetter;
@@ -66,5 +69,41 @@ public Long getMessagePayloadCompressedSize(final MyTrace myTrace) {
         public String getMessageId(final MyTrace myTrace, final Void unused) {
             return null;
         }
+
+        @Override
+        public List<String> getMessageHeader(MyTrace myTrace, String name) {
+            return Collections.emptyList();
+        }
+
+        @Override
+        public String getDestinationTemplate(MyTrace myTrace) {
+            return null;
+        }
+
+        @Override
+        public boolean isAnonymousDestination(MyTrace myTrace) {
+            return false;
+        }
+
+        @Override
+        public Long getMessageBodySize(MyTrace myTrace) {
+            return null;
+        }
+
+        @Override
+        public Long getMessageEnvelopeSize(MyTrace myTrace) {
+            return null;
+        }
+
+        @Override
+        public String getClientId(MyTrace myTrace) {
+            return null;
+        }
+
+        @Override
+        public Long getBatchMessageCount(MyTrace myTrace, Void unused) {
+            return null;
+        }
+
     }
 }
diff --git a/documentation/src/main/java/connectors/tracing/MyOpenTelemetryInstrumenter.java b/documentation/src/main/java/connectors/tracing/MyOpenTelemetryInstrumenter.java
@@ -3,12 +3,12 @@
 import org.eclipse.microprofile.reactive.messaging.Message;
 
 import io.opentelemetry.api.GlobalOpenTelemetry;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessageOperation;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesExtractor;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingSpanNameExtractor;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
 import io.opentelemetry.instrumentation.api.instrumenter.InstrumenterBuilder;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessageOperation;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingSpanNameExtractor;
 import io.smallrye.reactive.messaging.tracing.TracingUtils;
 
 /**

diff --git a/pom.xml b/pom.xml
@@ -90,8 +90,8 @@
 
     <kafka.version>3.7.1</kafka.version>
 
-    <opentelemetry.version>1.32.0-alpha</opentelemetry.version>
-    <opentelemetry-semconv.version>1.21.0-alpha</opentelemetry-semconv.version>
+    <opentelemetry.instrumentation.version>2.5.0-alpha</opentelemetry.instrumentation.version>
+    <opentelemetry-semconv.version>1.25.0-alpha</opentelemetry-semconv.version>
 
     <smallrye-vertx-mutiny-clients.version>3.13.0</smallrye-vertx-mutiny-clients.version>
     <smallrye-reactive-converters.version>3.0.0</smallrye-reactive-converters.version>
@@ -282,7 +282,7 @@
       <dependency>
         <groupId>io.opentelemetry.instrumentation</groupId>
         <artifactId>opentelemetry-instrumentation-bom-alpha</artifactId>
-        <version>${opentelemetry.version}</version>
+        <version>${opentelemetry.instrumentation.version}</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>

diff --git a/...qp/src/main/java/io/smallrye/reactive/messaging/amqp/tracing/AmqpAttributesExtractor.java b/...qp/src/main/java/io/smallrye/reactive/messaging/amqp/tracing/AmqpAttributesExtractor.java
@@ -1,9 +1,12 @@
 package io.smallrye.reactive.messaging.amqp.tracing;
 
+import java.util.Collections;
+import java.util.List;
+
 import io.opentelemetry.api.common.AttributesBuilder;
 import io.opentelemetry.context.Context;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
 import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
 import io.smallrye.reactive.messaging.amqp.AmqpMessage;
 
 public class AmqpAttributesExtractor implements AttributesExtractor<AmqpMessage<?>, Void> {
@@ -61,21 +64,44 @@ public String getConversationId(final AmqpMessage<?> amqpMessage) {
 
         // Recommended
         @Override
-        public Long getMessagePayloadSize(final AmqpMessage<?> amqpMessage) {
+        public String getMessageId(final AmqpMessage<?> amqpMessage, final Void unused) {
+            Object messageId = amqpMessage.getMessageId();
+            return messageId instanceof String ? (String) messageId : null;
+        }
+
+        @Override
+        public List<String> getMessageHeader(AmqpMessage<?> amqpMessage, String name) {
+            return Collections.emptyList();
+        }
+
+        @Override
+        public String getDestinationTemplate(AmqpMessage<?> amqpMessage) {
             return null;
         }
 
-        // Recommended
         @Override
-        public Long getMessagePayloadCompressedSize(final AmqpMessage<?> amqpMessage) {
+        public boolean isAnonymousDestination(AmqpMessage<?> amqpMessage) {
+            return false;
+        }
+
+        @Override
+        public Long getMessageBodySize(AmqpMessage<?> amqpMessage) {
             return null;
         }
 
-        // Recommended
         @Override
-        public String getMessageId(final AmqpMessage<?> amqpMessage, final Void unused) {
-            Object messageId = amqpMessage.getMessageId();
-            return messageId instanceof String ? (String) messageId : null;
+        public Long getMessageEnvelopeSize(AmqpMessage<?> amqpMessage) {
+            return null;
+        }
+
+        @Override
+        public String getClientId(AmqpMessage<?> amqpMessage) {
+            return null;
+        }
+
+        @Override
+        public Long getBatchMessageCount(AmqpMessage<?> amqpMessage, Void unused) {
+            return null;
         }
     }
 }
diff --git a/.../main/java/io/smallrye/reactive/messaging/amqp/tracing/AmqpOpenTelemetryInstrumenter.java b/.../main/java/io/smallrye/reactive/messaging/amqp/tracing/AmqpOpenTelemetryInstrumenter.java
@@ -5,12 +5,12 @@
 import org.eclipse.microprofile.reactive.messaging.Message;
 
 import io.opentelemetry.api.OpenTelemetry;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessageOperation;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesExtractor;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingSpanNameExtractor;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
 import io.opentelemetry.instrumentation.api.instrumenter.InstrumenterBuilder;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessageOperation;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingSpanNameExtractor;
 import io.smallrye.reactive.messaging.amqp.AmqpMessage;
 import io.smallrye.reactive.messaging.tracing.TracingUtils;
 

diff --git a/...ces/archetype-resources/src/main/java/tracing/__connectorPrefix__AttributesExtractor.java b/...ces/archetype-resources/src/main/java/tracing/__connectorPrefix__AttributesExtractor.java
@@ -3,7 +3,10 @@
 import io.opentelemetry.api.common.AttributesBuilder;
 import io.opentelemetry.context.Context;
 import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
+
+import java.util.Collections;
+import java.util.List;
 
 public class ${connectorPrefix}AttributesExtractor implements AttributesExtractor<${connectorPrefix}Trace, Void> {
     private final MessagingAttributesGetter<${connectorPrefix}Trace, Void> messagingAttributesGetter;
@@ -53,17 +56,42 @@ public String getConversationId(final ${connectorPrefix}Trace myTrace) {
         }
 
         @Override
-        public Long getMessagePayloadSize(final ${connectorPrefix}Trace myTrace) {
+        public String getMessageId(final ${connectorPrefix}Trace myTrace, final Void unused) {
             return null;
         }
 
         @Override
-        public Long getMessagePayloadCompressedSize(final ${connectorPrefix}Trace myTrace) {
+        public List<String> getMessageHeader(final ${connectorPrefix}Trace myTrace, final String name) {
+            return Collections.emptyList();
+        }
+
+        @Override
+        public String getDestinationTemplate(final ${connectorPrefix}Trace myTrace) {
             return null;
         }
 
         @Override
-        public String getMessageId(final ${connectorPrefix}Trace myTrace, final Void unused) {
+        public boolean isAnonymousDestination(final ${connectorPrefix}Trace myTrace) {
+            return false;
+        }
+
+        @Override
+        public Long getMessageBodySize(final ${connectorPrefix}Trace myTrace) {
+            return null;
+        }
+
+        @Override
+        public Long getMessageEnvelopeSize(final ${connectorPrefix}Trace myTrace) {
+            return null;
+        }
+
+        @Override
+        public String getClientId(final ${connectorPrefix}Trace myTrace) {
+            return null;
+        }
+
+        @Override
+        public Long getBatchMessageCount(final ${connectorPrefix}Trace myTrace, final Void unused) {
             return null;
         }
     }

diff --git a/...chetype-resources/src/main/java/tracing/__connectorPrefix__OpenTelemetryInstrumenter.java b/...chetype-resources/src/main/java/tracing/__connectorPrefix__OpenTelemetryInstrumenter.java
@@ -5,10 +5,10 @@
 import io.opentelemetry.api.GlobalOpenTelemetry;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
 import io.opentelemetry.instrumentation.api.instrumenter.InstrumenterBuilder;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessageOperation;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingSpanNameExtractor;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessageOperation;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingSpanNameExtractor;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesExtractor;
 import io.smallrye.reactive.messaging.tracing.TracingUtils;
 
 /**

diff --git a/.../src/main/java/io/smallrye/reactive/messaging/kafka/tracing/KafkaAttributesExtractor.java b/.../src/main/java/io/smallrye/reactive/messaging/kafka/tracing/KafkaAttributesExtractor.java
@@ -1,15 +1,17 @@
 package io.smallrye.reactive.messaging.kafka.tracing;
 
 import static io.opentelemetry.semconv.SemanticAttributes.MESSAGING_CONSUMER_ID;
-import static io.opentelemetry.semconv.SemanticAttributes.MESSAGING_KAFKA_CLIENT_ID;
 import static io.opentelemetry.semconv.SemanticAttributes.MESSAGING_KAFKA_CONSUMER_GROUP;
 import static io.opentelemetry.semconv.SemanticAttributes.MESSAGING_KAFKA_MESSAGE_OFFSET;
 import static io.opentelemetry.semconv.SemanticAttributes.MESSAGING_KAFKA_PARTITION;
 
+import java.util.Collections;
+import java.util.List;
+
 import io.opentelemetry.api.common.AttributesBuilder;
 import io.opentelemetry.context.Context;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
 import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
 
 public class KafkaAttributesExtractor implements AttributesExtractor<KafkaTrace, Void> {
     private final MessagingAttributesGetter<KafkaTrace, Void> messagingAttributesGetter;
@@ -39,9 +41,6 @@ public void onStart(final AttributesBuilder attributes, final Context parentCont
         if (groupId != null) {
             attributes.put(MESSAGING_KAFKA_CONSUMER_GROUP, groupId);
         }
-        if (clientId != null) {
-            attributes.put(MESSAGING_KAFKA_CLIENT_ID, clientId);
-        }
     }
 
     @Override
@@ -80,17 +79,45 @@ public String getConversationId(final KafkaTrace kafkaTrace) {
         }
 
         @Override
-        public Long getMessagePayloadSize(final KafkaTrace kafkaTrace) {
+        public String getMessageId(final KafkaTrace kafkaTrace, final Void unused) {
             return null;
         }
 
         @Override
-        public Long getMessagePayloadCompressedSize(final KafkaTrace kafkaTrace) {
+        public List<String> getMessageHeader(KafkaTrace kafkaTrace, String name) {
+            return Collections.emptyList();
+        }
+
+        @Override
+        public String getDestinationTemplate(KafkaTrace kafkaTrace) {
             return null;
         }
 
         @Override
-        public String getMessageId(final KafkaTrace kafkaTrace, final Void unused) {
+        public boolean isAnonymousDestination(KafkaTrace kafkaTrace) {
+            return false;
+        }
+
+        @Override
+        public Long getMessageBodySize(KafkaTrace kafkaTrace) {
+            return null;
+        }
+
+        @Override
+        public Long getMessageEnvelopeSize(KafkaTrace kafkaTrace) {
+            return null;
+        }
+
+        @Override
+        public String getClientId(KafkaTrace kafkaTrace) {
+            if (kafkaTrace.getClientId() == null) {
+                return null;
+            }
+            return kafkaTrace.getClientId();
+        }
+
+        @Override
+        public Long getBatchMessageCount(KafkaTrace kafkaTrace, Void unused) {
             return null;
         }
     }

diff --git a/...ain/java/io/smallrye/reactive/messaging/kafka/tracing/KafkaOpenTelemetryInstrumenter.java b/...ain/java/io/smallrye/reactive/messaging/kafka/tracing/KafkaOpenTelemetryInstrumenter.java
@@ -5,12 +5,12 @@
 import org.eclipse.microprofile.reactive.messaging.Message;
 
 import io.opentelemetry.api.OpenTelemetry;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessageOperation;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesExtractor;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter;
+import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingSpanNameExtractor;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
 import io.opentelemetry.instrumentation.api.instrumenter.InstrumenterBuilder;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessageOperation;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesExtractor;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingAttributesGetter;
-import io.opentelemetry.instrumentation.api.instrumenter.messaging.MessagingSpanNameExtractor;
 import io.smallrye.reactive.messaging.tracing.TracingUtils;
 
 /**