OpenTelemetry HTTP header Propogation

[linktech1]

Is there not a way to auto propagate the parentId and traceId in the RestEasy reactive client headers? We can make it work using ClientRequestFilter or org.eclipse.microprofile.rest.client.propagateHeaders=traceparent,tracestate
but I would rather not have to add any of these to propagate the W3C Trace Context headers.

[quarkus-bot[bot]]

/cc @brunobat (opentelemetry), @radcortez (opentelemetry)

[brunobat]

quarkus-rest-client-reactive-jackson has OTel support and should have context propagation. Do you have a code example that doesn't work?

[linktech1]

I took the Otel example and added rest client. Without using org.eclipse.microprofile.rest.client.propagateHeaders=traceparent,tracestate
No Otel headers are sent.

=============================================================
package org.acme.opentelemetry;

import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.Context;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.UriInfo;

import org.eclipse.microprofile.rest.client.RestClientBuilder;
import org.eclipse.microprofile.rest.client.inject.RestClient;
import org.jboss.logging.Logger;

import io.smallrye.mutiny.Uni;
import io.smallrye.mutiny.tuples.Tuple3;

@path("/")
public class TracedResource {

private static final Logger LOG = Logger.getLogger(TracedResource.class);

@Context
UriInfo uriInfo;

@RestClient
Countries countries;

@GET
@Path("/hello")
@Produces(MediaType.TEXT_PLAIN)
public String hello() {
    LOG.info("hello");
    return "hello";
}

@GET
@Path("/all")
@Produces(MediaType.APPLICATION_JSON)
public String all() {
    LOG.info("all");
    countries.all();
    countries.all();
    return countries.all();
}

@GET
@Path("/allAsync")
@Produces(MediaType.APPLICATION_JSON)
public Uni<String> allAsync()
{
	Uni<Tuple3<String, String, String>> tuple = 
		Uni
			.combine()
			.all()
			.unis(
				countries.allAsync(), 
				countries.allAsync(),
				countries.allAsync()) .asTuple();
    LOG.info("allAsync");
	return tuple.chain(aTuple -> 
		getTupleContents(aTuple.getItem1()));
	
}

public Uni<String> getTupleContents(String tupleContents)
{
	return Uni.createFrom().item(tupleContents);
}

@GET
@Path("/chain")
@Produces(MediaType.TEXT_PLAIN)
public String chain() {
    ResourceClient resourceClient = RestClientBuilder.newBuilder()
            .baseUri(uriInfo.getBaseUri())
            .register((MyFilter.class))
            .build(ResourceClient.class);
    return "chain -> " + resourceClient.hello();
}

}

================================================================

package org.acme.opentelemetry;

import org.eclipse.microprofile.rest.client.annotation.RegisterClientHeaders;
import org.eclipse.microprofile.rest.client.annotation.RegisterProvider;
import org.eclipse.microprofile.rest.client.inject.RegisterRestClient;

import io.smallrye.mutiny.Uni;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.MediaType;

@path("")
@RegisterRestClient(configKey="countries")
@produces("application/json")
@RegisterClientHeaders
@RegisterProvider(MyFilter.class)
public interface Countries {
@get
@path("/all")
@produces(MediaType.APPLICATION_JSON)
String all();

   @GET
    @Path("/all")
    @Produces(MediaType.APPLICATION_JSON)
   Uni<String> allAsync();

}

===========================================================

quarkus.application.name=myservice
quarkus.otel.exporter.otlp.traces.endpoint=http://localhost:4317
quarkus.otel.exporter.otlp.traces.headers=Authorization=Bearer my_secret
quarkus.log.console.format=%d{HH:mm:ss} %-5p traceId=%X{traceId}, parentId=%X{parentId}, spanId=%X{spanId}, sampled=%X{sampled} [%c{2.}] (%t) %s%e%n

##org.eclipse.microprofile.rest.client.propagateHeaders=traceparent,tracestate

quarkus.rest-client.countries.url=https://restcountries.com/v3.1/

quarkus.log.min-level=ALL

quarkus.http.access-log.enabled=true
quarkus.http.access-log.pattern=%h %l %u %t "%r" %s %b\n%{ALL_REQUEST_HEADERS}
##quarkus.http.access-log.pattern=%{REMOTE_HOST} %l %{REMOTE_USER} %{DATE_TIME} "%{REQUEST_LINE}" %{RESPONSE_CODE} %b %{RESPONSE_TIME} %T

quarkus.http.access-log.log-to-file=true
quarkus.log.category."org.apache.http".level=DEBUG

quarkus.rest-client.logging.scope=all
quarkus.rest-client.logging.body-limit=1024
quarkus.log.category."org.jboss.resteasy.reactive.client.logging".level=DEBUG

===========================================================

4.0.0
org.acme
opentelemetry-quickstart
1.0.0-SNAPSHOT

<quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
<quarkus.platform.group-id>io.quarkus.platform</quarkus.platform.group-id>
<quarkus.platform.version>3.4.3</quarkus.platform.version>
<surefire-plugin.version>3.1.2</surefire-plugin.version>
<maven.compiler.source>17</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.target>17</maven.compiler.target>




${quarkus.platform.group-id}
${quarkus.platform.artifact-id}
${quarkus.platform.version}
pom
import





io.quarkus
quarkus-resteasy-reactive

<dependency>
  <groupId>io.quarkus</groupId>
  <artifactId>quarkus-resteasy-reactive-jackson</artifactId>
</dependency>

<dependency>
  <groupId>io.quarkus</groupId>
  <artifactId>quarkus-junit5</artifactId>
  <scope>test</scope>
</dependency>
<dependency>
  <groupId>io.rest-assured</groupId>
  <artifactId>rest-assured</artifactId>
  <scope>test</scope>
</dependency>
<dependency>
  <groupId>io.quarkus</groupId>
  <artifactId>quarkus-opentelemetry</artifactId>
</dependency>
<dependency>
	<groupId>io.quarkus</groupId>
	<artifactId>quarkus-micrometer-registry-prometheus</artifactId>
</dependency>

<dependency>
  <groupId>io.quarkus</groupId>
  <artifactId>quarkus-rest-client-reactive</artifactId>
</dependency>
<dependency>
  <groupId>io.quarkus</groupId>
  <artifactId>quarkus-rest-client-reactive-jackson</artifactId>
</dependency>

<dependency>
  <groupId>io.quarkus</groupId>
  <artifactId>quarkus-info</artifactId>
</dependency>

maven-surefire-plugin ${surefire-plugin.version} org.jboss.logmanager.LogManager ${maven.home} ${quarkus.platform.group-id} quarkus-maven-plugin ${quarkus.platform.version} build native native native maven-failsafe-plugin ${surefire-plugin.version} integration-test verify ${project.build.directory}/${project.build.finalName}-runner org.jboss.logmanager.LogManager ${maven.home}

==================================================================

[brunobat]

I'd say that's a bug, can you please file an issue for it?