diff --git a/docs/src/main/asciidoc/_spans.adoc b/docs/src/main/asciidoc/_spans.adoc index 7c4b4ed83..5be77de3c 100644 --- a/docs/src/main/asciidoc/_spans.adoc +++ b/docs/src/main/asciidoc/_spans.adoc @@ -400,6 +400,24 @@ IMPORTANT: All tags and events must be prefixed with `kafka.` prefix! |kafka.topic|Name of the Kafka topic. |=== +=== Kafka On Message Span + +> Span created on the Kafka consumer side when using a MessageListener. + +**Span name** `kafka.on-message`. + +Fully qualified name of the enclosing class `org.springframework.cloud.sleuth.instrument.kafka.SleuthKafkaSpan` + +IMPORTANT: All tags and events must be prefixed with `kafka.` prefix! + +.Tag Keys +|=== +|Name | Description +|kafka.offset|Kafka offset number. +|kafka.partition|Kafka partition number. +|kafka.topic|Name of the Kafka topic. +|=== + === Kafka Producer Span > Span created on the Kafka consumer side. diff --git a/spring-cloud-sleuth-brave/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/SkipPatternSamplerTests.java b/spring-cloud-sleuth-brave/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/SkipPatternSamplerTests.java index 047563a57..59e49ca45 100644 --- a/spring-cloud-sleuth-brave/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/SkipPatternSamplerTests.java +++ b/spring-cloud-sleuth-brave/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/SkipPatternSamplerTests.java @@ -98,4 +98,5 @@ public class SkipPatternSamplerTests { then(sampler.trySample(this.request)).isNull(); } + }