Akka instrumentation doesn't work in Java 17 application?

[vitalkrasilnikau2]

Hi, I have Java 17 gRPC application with Akka 2.9.5 running inside. I implemented gRPC trace interceptor to create Kamon context and root span and also implemented manual context propagation for completable futures with Kamon bundle v2.7.4 for Scala 2.13. It looks good except Akka cluster part. It seems like Akka instrumentation doesn't work and the context is not propagated into Akka world. Kamon Status Page shows both Akka and Akka Remote modules installed.

I tried different filters

  instrumentation.akka.filters {
    actors.trace {
      includes = [
        "*/system/sharding**"
      ]
    }
  }

but no success.

This is an example of context propagation for completable futures.

public class TracingHelper {

  private static final Logger logger = LoggerFactory.getLogger(TracingHelper.class);

  public static <T> CompletionStage<T> withSpan(String spanName, Supplier<CompletionStage<T>> futureSupplier) {
    logger.debug("Changing span from '{}' to '{}'", Kamon.currentSpan().operationName(), spanName);
    kamon.context.Context traceContext = Kamon.currentContext();
    kamon.trace.Span span = Kamon.spanBuilder(spanName).start();

    return Kamon.runWithSpan(span, futureSupplier::get).whenComplete((x, e) ->
        Kamon.runWithContext(traceContext, () -> Kamon.runWithSpan(span, () -> {
          logger.debug("Finishing span '{}'", Kamon.currentSpan().operationName());
          span.finish();
          return true;
        })));
  }
}

And this is Akka entity ask call which do not propagate the context to Akka. The proper context is established in getStreamsPage function and I can see the span for GetStreamsPageAsk in Jaeger but not spans for actor messages.

  private CompletableFuture<Reply> getStreamsPage(long skip) {
    return TracingHelper.withSpan("GetStreamsPageAsk", () ->
        getEntityRef().ask(
            (ActorRef<Reply> actorRef) ->
                ImmutableCommand.ListStreams.builder()
                    .caller(actorRef)
                    .skip(skip)
                    .limit(streamsPageSize)
                    .build(),
            Duration.ofSeconds(timeoutSeconds))).toCompletableFuture();
  }

Is there something missing? Thanks.