Otel 1.28 updates for RM Kafka Otel test case

quarkusio · Aug 1, 2023 · 8c06936 · 8c06936
1 parent 0f035bf
commit 8c06936
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...y-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java b/...y-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java
@@ -134,12 +134,11 @@ private static void verifyProducer(Map<String, Object> spanData,
         Assertions.assertNotNull(spanData.get("spanId"));
         verifyResource(spanData, parentSpanData);
 
-        Assertions.assertEquals(topic + " send", spanData.get("name"));
+        Assertions.assertEquals(topic + " publish", spanData.get("name"));
         Assertions.assertEquals(SpanKind.PRODUCER.toString(), spanData.get("kind"));
         Assertions.assertTrue((Boolean) spanData.get("ended"));
         Assertions.assertFalse((Boolean) spanData.get("parent_remote"));
 
-        Assertions.assertEquals("topic", spanData.get("attr_messaging.destination.kind"));
         Assertions.assertEquals("kafka", spanData.get("attr_messaging.system"));
         Assertions.assertEquals(topic, spanData.get("attr_messaging.destination.name"));
     }
@@ -157,7 +156,6 @@ private static void verifyConsumer(Map<String, Object> spanData,
         Assertions.assertTrue((Boolean) spanData.get("ended"));
         Assertions.assertEquals(parentRemote, spanData.get("parent_remote"));
 
-        Assertions.assertEquals("topic", spanData.get("attr_messaging.destination.kind"));
         Assertions.assertEquals("opentelemetry-integration-test - kafka-consumer-" + channel,
                 spanData.get("attr_messaging.consumer.id"));
         Assertions.assertEquals("kafka", spanData.get("attr_messaging.system"));