From 7032440fed1fa561641ab2d644bd2177eb04b1ff Mon Sep 17 00:00:00 2001 From: buildmaster Date: Tue, 14 Mar 2023 19:20:26 +0000 Subject: [PATCH] Bumping versions --- .../kafka/TracingKafkaReceiver.java | 26 +++++++++++-------- 1 file changed, 15 insertions(+), 11 deletions(-) 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 */