added set ct for records && updated setHeaders (#150 )

Reviewed-on: #150 Co-authored-by: Evstigneev Denis <danteevstigneev@yandex.ru> Co-committed-by: Evstigneev Denis <danteevstigneev@yandex.ru>
2025-01-21 15:29:02 +03:00
1 changed files with 3 additions and 2 deletions
--- a/carrier.go
+++ b/carrier.go
@@ -1,11 +1,12 @@
 package kgo

 import (
-	"github.com/twmb/franz-go/pkg/kgo"
-	"go.unistack.org/micro/v3/metadata"
 	"net/http"
 	"slices"
 	"strings"
+
+	"github.com/twmb/franz-go/pkg/kgo"
+	"go.unistack.org/micro/v3/metadata"
 )

 // RecordCarrier injects and extracts traces from a kgo.Record.