diff --git a/src/NATS.Client.Core/NatsConnection.RequestReply.cs b/src/NATS.Client.Core/NatsConnection.RequestReply.cs
index f0dec997f..47a58763f 100644
--- a/src/NATS.Client.Core/NatsConnection.RequestReply.cs
+++ b/src/NATS.Client.Core/NatsConnection.RequestReply.cs
@@ -45,7 +45,9 @@ public async ValueTask<NatsMsg<TReply>> RequestAsync<TRequest, TReply>(
                     using var rt = _replyTaskFactory.CreateReplyTask(replySerializer, replyOpts.Timeout);
                     requestSerializer ??= Opts.SerializerRegistry.GetSerializer<TRequest>();
                     await PublishAsync(subject, data, headers, rt.Subject, requestSerializer, requestOpts, cancellationToken).ConfigureAwait(false);
-                    return await rt.GetResultAsync(cancellationToken).ConfigureAwait(false);
+                    var msg = await rt.GetResultAsync(cancellationToken).ConfigureAwait(false);
+                    msg.Headers?.Activity?.Dispose();
+                    return msg;
                 }
 
                 await using var sub1 = await CreateRequestSubAsync<TRequest, TReply>(subject, data, headers, requestSerializer, replySerializer, requestOpts, replyOpts, cancellationToken)