Merge branch 'feat/DEX-2551/write-otel-trace_id-to-outgoing-message-l…

…ogs' into 'master'

[DEX-2551] feat: write otel trace_id to outgoing message logs

Closes DEX-2551

See merge request nstmrt/rubygems/sbmt-kafka_consumer!69

CHANGELOG.md

@@ -13,6 +13,12 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ### Fixed
 
+## [3.2.2] - 2024-09-23
+
+### Fixed
+
+- log OTEL `trace_id`
+
 ## [3.2.1] - 2024-09-20
 
 ### Fixed

lib/sbmt/kafka_consumer/base_consumer.rb

@@ -162,7 +162,11 @@ def call_middlewares(message, middlewares)
       end
 
       def trace_id
-        @trace_id ||= SecureRandom.base58
+        return nil unless defined?(::OpenTelemetry)
+
+        context = ::OpenTelemetry::Trace.current_span.context
+
+        context.valid? ? context.hex_trace_id : nil
       end
 
       def config

lib/sbmt/kafka_consumer/version.rb

@@ -2,6 +2,6 @@
 
 module Sbmt
   module KafkaConsumer
-    VERSION = "3.2.1"
+    VERSION = "3.2.2"
   end
 end