SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Bumping versions

Browse Source
This commit is contained in:
buildmaster
2023-03-14 19:20:26 +00:00
parent 25606b2896
commit 7032440fed
1 changed files with 15 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaReceiver.java
View File

@@ -48,25 +48,29 @@ public class TracingKafkaReceiver<K, V> implements KafkaReceiver<K, V> {
}
/**
* 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 <K> Key of the record
* @param <V> Value of the record
*/
public static <K, V> KafkaReceiver<K, V> create(ReactiveKafkaTracingPropagator reactiveKafkaTracingPropagator,
ReceiverOptions<K, V> 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 <K> Key of the record
* @param <V> Value of the record
*/