Skip to content

Commit 884a43d

Browse files
committed
GH-2198: Fix Race in ObservationTests
1 parent e531a0f commit 884a43d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

spring-kafka/src/test/java/org/springframework/kafka/support/micrometer/ObservationTests.java

+1
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@ void endToEnd(@Autowired Listener listener, @Autowired KafkaTemplate<Integer, St
9696
SimpleSpan span = spans.poll();
9797
assertThat(span.getTags()).containsEntry("spring.kafka.template.name", "template");
9898
assertThat(span.getName()).isEqualTo("observation.testT1 send");
99+
await().until(() -> spans.peekFirst().getTags().size() == 3);
99100
span = spans.poll();
100101
assertThat(span.getTags())
101102
.containsAllEntriesOf(

0 commit comments

Comments
 (0)