chore: more traces

Author: adityachoudhari26

apps/workspace-engine/pkg/kafka/consumer.go

@@ -2,6 +2,7 @@ package kafka
 
 import (
 	"context"
+	"fmt"
 	"workspace-engine/pkg/db"
 
 	"github.com/charmbracelet/log"
@@ -63,6 +64,8 @@ func setOffsets(ctx context.Context, consumer *kafka.Consumer, partitionWorkspac
 	ctx, span := tracer.Start(ctx, "setOffsets")
 	defer span.End()
 
+	span.SetAttributes(attribute.String("partition_workspace_map", fmt.Sprintf("%+v", partitionWorkspaceMap)))
+
 	for partition, workspaceIDs := range partitionWorkspaceMap {
 		snapshots, err := db.GetLatestWorkspaceSnapshots(ctx, workspaceIDs)
 		if err != nil {