diff --git a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaReceiver.java b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaReceiver.java index 8536363be..2a439564d 100644 --- a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaReceiver.java +++ b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaReceiver.java @@ -48,25 +48,29 @@ public class TracingKafkaReceiver implements KafkaReceiver { } /** - * Creates KafkaReceiver that will de decorated by tracing propagator to provide kafka consumer publishing elements - * containing tracing context in their reactor context. - * @param reactiveKafkaTracingPropagator Instance of trace propagation decorator. Should be available in spring application context as a bean. - * @param options Options to pass for underlying {@link KafkaReceiver#create(ReceiverOptions)} + * Creates KafkaReceiver that will de decorated by tracing propagator to provide kafka + * consumer publishing elements containing tracing context in their reactor context. + * @param reactiveKafkaTracingPropagator Instance of trace propagation decorator. + * Should be available in spring application context as a bean. + * @param options Options to pass for underlying + * {@link KafkaReceiver#create(ReceiverOptions)} * @param Key of the record * @param Value of the record */ public static KafkaReceiver create(ReactiveKafkaTracingPropagator reactiveKafkaTracingPropagator, ReceiverOptions options) { - return new TracingKafkaReceiver<>(reactiveKafkaTracingPropagator, - KafkaReceiver.create(options)); + return new TracingKafkaReceiver<>(reactiveKafkaTracingPropagator, KafkaReceiver.create(options)); } /** - * Creates KafkaReceiver that will de decorated by tracing propagator to provide kafka consumer publishing elements - * containing tracing context in their reactor context. - * @param reactiveKafkaTracingPropagator Instance of trace propagation decorator. Should be available in spring application context as a bean. - * @param factory Custom factory to provide for underlying {@link KafkaReceiver#create(ConsumerFactory, ReceiverOptions)} - * @param options Options to provide for underlying {@link KafkaReceiver#create(ConsumerFactory, ReceiverOptions)} + * Creates KafkaReceiver that will de decorated by tracing propagator to provide kafka + * consumer publishing elements containing tracing context in their reactor context. + * @param reactiveKafkaTracingPropagator Instance of trace propagation decorator. + * Should be available in spring application context as a bean. + * @param factory Custom factory to provide for underlying + * {@link KafkaReceiver#create(ConsumerFactory, ReceiverOptions)} + * @param options Options to provide for underlying + * {@link KafkaReceiver#create(ConsumerFactory, ReceiverOptions)} * @param Key of the record * @param Value of the record */