9
9
"go.opentelemetry.io/otel"
10
10
"go.opentelemetry.io/otel/attribute"
11
11
"go.opentelemetry.io/otel/propagation"
12
- semconv "go.opentelemetry.io/otel/semconv/v1.21 .0"
12
+ semconv "go.opentelemetry.io/otel/semconv/v1.24 .0"
13
13
"go.opentelemetry.io/otel/trace"
14
14
15
15
"github.com/IBM/sarama"
@@ -27,9 +27,9 @@ func NewOTelInterceptor(groupID string) *OTelInterceptor {
27
27
oi .tracer = otel .Tracer ("github.com/open-telemetry/opentelemetry-demo/accountingservice/sarama" )
28
28
29
29
oi .fixedAttrs = []attribute.KeyValue {
30
- semconv .MessagingSystem ( "kafka" ) ,
30
+ semconv .MessagingSystemKafka ,
31
31
semconv .MessagingKafkaConsumerGroup (groupID ),
32
- semconv .NetTransportTCP ,
32
+ semconv .NetworkTransportTCP ,
33
33
}
34
34
return & oi
35
35
}
@@ -52,7 +52,7 @@ func (oi *OTelInterceptor) OnConsume(msg *sarama.ConsumerMessage) {
52
52
trace .WithAttributes (
53
53
semconv .MessagingDestinationName (msg .Topic ),
54
54
semconv .MessagingKafkaMessageOffset (int (msg .Offset )),
55
- semconv .MessagingMessagePayloadSizeBytes (len (msg .Value )),
55
+ semconv .MessagingMessageBodySize (len (msg .Value )),
56
56
semconv .MessagingOperationReceive ,
57
57
semconv .MessagingKafkaDestinationPartition (int (msg .Partition )),
58
58
),
0 commit comments