Open davidmelia opened 1 year ago
@patpatpat123 ^^
See some related discussion here: https://github.com/reactor/reactor-kafka/issues/321.
I think even if we don't something in the framework for simple operators, those flatMap
, concatMap
in the end-user code must be instrumented respectively.
I have the same issue.
Hi, I have updated my prototype in the branch https://github.com/davidmelia/spring-boot-kafka-consumer-tracing/tree/potential_fix using the new reactor Hooks.enableAutomaticContextPropagation(); which simulates the legacy Spring Cloud Sleuth
This solves the issue for the non reactive kafka binder.
Obviously as per the other thread the reactor kafka currently doesn't show trace IDs using this method.
Thanks
Would be great if reactor kafka can leverage the latest micrometer with reactive support on reactor kafka level!
A fix/workaround would be great here?....
Hi,
I have created the prototype https://github.com/davidmelia/spring-boot-kafka-consumer-tracing to illustrate an issue summarised by
If you follow the README after hitting http://localhost:8080/sendMessage you will see
I have found no way to get the reactor kafka binder to log the trace ID nor can I get the following statement to log the trace ID in any binder
return Mono.just("OK").delayElement(Duration.ofMillis(10)).doOnSuccess(r -> log.info(...);
Thanks