Remove unecessary traces from Server

server/app/server.go

@@ -27,7 +27,6 @@ import (
 	"github.com/topfreegames/eventsgateway/v4/server/logger"
 	"github.com/topfreegames/eventsgateway/v4/server/sender"
 	pb "github.com/topfreegames/protos/eventsgateway/grpc/generated"
-	"go.opentelemetry.io/otel"
 )
 
 // Server struct
@@ -49,8 +48,6 @@ func (s *Server) SendEvent(
 	ctx context.Context,
 	req *pb.Event,
 ) (*pb.SendEventResponse, error) {
-	_, span := otel.Tracer("app.server").Start(ctx, "app.server.SendEvent")
-	defer span.End()
 	if err := s.sender.SendEvent(ctx, req); err != nil {
 		return nil, err
 	}

server/forwarder/kafka.go

@@ -6,6 +6,7 @@ import (
 	"github.com/IBM/sarama"
 	"github.com/spf13/viper"
 	"go.opentelemetry.io/otel"
+	"go.opentelemetry.io/otel/attribute"
 	"log"
 	"os"
 	"strings"
@@ -57,6 +58,7 @@ func NewKafkaForwarder(config *viper.Viper) (*KafkaForwarder, error) {
 
 func (k KafkaForwarder) Produce(ctx context.Context, topic string, message []byte) (int32, int64, error) {
 	_, span := otel.Tracer("forwarder.kafka").Start(ctx, "forwarder.kafka.Produce")
+	span.SetAttributes(attribute.Key("kafkaTopic").String(topic))
 	defer span.End()
 
 	prefixedTopic := fmt.Sprintf("%s%s", k.topicPrefix, topic)

server/sender/kafka.go

@@ -10,8 +10,6 @@ package sender
 import (
 	"bytes"
 	"context"
-	"go.opentelemetry.io/otel"
-	"go.opentelemetry.io/otel/attribute"
 	"sync"
 	"time"
 
@@ -69,9 +67,6 @@ func (k *KafkaSender) SendEvent(
 	ctx context.Context,
 	event *pb.Event,
 ) error {
-	_, span := otel.Tracer("sender.kafka").Start(ctx, "sender.kafka.SendEvent")
-	defer span.End()
-
 	l := k.logger.WithFields(map[string]interface{}{
 		"topic": event.GetTopic(),
 		"event": event,
@@ -108,7 +103,6 @@ func (k *KafkaSender) SendEvent(
 	}
 
 	topic := event.GetTopic()
-	span.SetAttributes(attribute.Key("kafkaTopic").String(topic))
 
 	partition, offset, err := k.producer.Produce(ctx, topic, buf.Bytes())