diff --git a/java-client/src/main/java/co/elastic/clients/transport/instrumentation/OpenTelemetryForElasticsearch.java b/java-client/src/main/java/co/elastic/clients/transport/instrumentation/OpenTelemetryForElasticsearch.java index ec8afb223..6e56e43d8 100644 --- a/java-client/src/main/java/co/elastic/clients/transport/instrumentation/OpenTelemetryForElasticsearch.java +++ b/java-client/src/main/java/co/elastic/clients/transport/instrumentation/OpenTelemetryForElasticsearch.java @@ -185,10 +185,13 @@ OTelContext(TRequest request, Endpoint endpoint) { } this.endpointId = endpointId; - span = tracer.spanBuilder(endpointId).setSpanKind(SpanKind.CLIENT).startSpan(); + span = tracer.spanBuilder(endpointId).setSpanKind(SpanKind.CLIENT) + .setAttribute(ATTR_DB_SYSTEM, "elasticsearch") + .setAttribute(ATTR_DB_OPERATION, endpointId) + .startSpan(); + if (span.isRecording()) { - span.setAttribute(ATTR_DB_SYSTEM, "elasticsearch"); - span.setAttribute(ATTR_DB_OPERATION, endpointId); + span.setAttribute(ATTR_HTTP_REQUEST_METHOD, endpoint.method(request)); for (Map.Entry pathParamEntry : endpoint.pathParameters(request).entrySet()) {