fix test

shalk · shalk · commit ec2ff35df0b2 · 2024-10-22T17:43:26.000+08:00
diff --git a/instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/KafkaStreamsSuppressReceiveSpansTest.java b/instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/KafkaStreamsSuppressReceiveSpansTest.java
@@ -240,7 +240,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()
                             MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP,
                             "test-application"));
                   }
-                  span.hasName(STREAM_PENDING + " process")
+                  span.hasName(STREAM_PROCESSED + " process")
                       .hasKind(SpanKind.CONSUMER)
                       .hasParent(trace.getSpan(2))
                       .hasAttributesSatisfyingExactly(assertions);

Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()`
`240`	`240`	`MessagingIncubatingAttributes.MESSAGING_KAFKA_CONSUMER_GROUP,`
`241`	`241`	`"test-application"));`
`242`	`242`	`}`
`243`		`- span.hasName(STREAM_PENDING + " process")`
	`243`	`+ span.hasName(STREAM_PROCESSED + " process")`
`244`	`244`	`.hasKind(SpanKind.CONSUMER)`
`245`	`245`	`.hasParent(trace.getSpan(2))`
`246`	`246`	`.hasAttributesSatisfyingExactly(assertions);`