diff --git a/examples/pom.xml b/examples/pom.xml
index 1732769b8..463b36b84 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -22,7 +22,7 @@
${java.version}
${java.version}
false
- 0.14.0
+ 1.14.0
1.41.0
2.16.3
diff --git a/examples/src/main/java/io/dapr/examples/OpenTelemetryConfig.java b/examples/src/main/java/io/dapr/examples/OpenTelemetryConfig.java
index 84909e291..a9cd028b3 100644
--- a/examples/src/main/java/io/dapr/examples/OpenTelemetryConfig.java
+++ b/examples/src/main/java/io/dapr/examples/OpenTelemetryConfig.java
@@ -20,9 +20,10 @@ import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.api.trace.propagation.W3CTraceContextPropagator;
import io.opentelemetry.context.Context;
import io.opentelemetry.context.propagation.ContextPropagators;
-import io.opentelemetry.context.propagation.TextMapPropagator;
+import io.opentelemetry.context.propagation.TextMapSetter;
import io.opentelemetry.exporter.zipkin.ZipkinSpanExporter;
import io.opentelemetry.sdk.OpenTelemetrySdk;
+import io.opentelemetry.sdk.resources.Resource;
import io.opentelemetry.sdk.trace.SdkTracerProvider;
import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
import org.springframework.beans.factory.annotation.Autowired;
@@ -59,18 +60,23 @@ public class OpenTelemetryConfig {
* Creates an opentelemetry instance.
* @return OpenTelemetry.
*/
- public static OpenTelemetry createOpenTelemetry() {
+ public static OpenTelemetrySdk createOpenTelemetry() {
// Only exports to Zipkin if it is up. Otherwise, ignore it.
// This is helpful to avoid exceptions for examples that do not require Zipkin.
if (isZipkinUp()) {
+ Resource serviceResource = Resource.getDefault()
+ .toBuilder()
+ .put("service.name", InvokeClient.class.getName()) // Use ResourceAttributes constant
+ .build();
String httpUrl = String.format("http://localhost:%d", ZIPKIN_PORT);
+
ZipkinSpanExporter zipkinExporter =
ZipkinSpanExporter.builder()
.setEndpoint(httpUrl + ENDPOINT_V2_SPANS)
- .setServiceName(InvokeClient.class.getName())
.build();
SdkTracerProvider sdkTracerProvider = SdkTracerProvider.builder()
+ .setResource(serviceResource)
.addSpanProcessor(SimpleSpanProcessor.create(zipkinExporter))
.build();
@@ -100,7 +106,7 @@ public class OpenTelemetryConfig {
*/
public static reactor.util.context.Context getReactorContext(Context context) {
Map map = new HashMap<>();
- TextMapPropagator.Setter