fix goroutine labels

Author: rekby

internal/topic/topicreaderinternal/committer.go

@@ -3,7 +3,6 @@ package topicreaderinternal
 import (
 	"context"
 	"errors"
-	"fmt"
 	"sync/atomic"
 	"time"
 
@@ -58,7 +57,7 @@ func newCommitterStopped(tracer *trace.Topic, lifeContext context.Context, mode
 		mode:             mode,
 		clock:            clockwork.NewRealClock(),
 		send:             send,
-		backgroundWorker: *background.NewWorker(lifeContext, fmt.Sprintf("ydb-topic-reader-committer: %v", readerID)),
+		backgroundWorker: *background.NewWorker(lifeContext, "ydb-topic-reader-committer"),
 		tracer:           tracer,
 	}
 	res.initChannels()

internal/topic/topicreaderinternal/stream_reader_impl.go

@@ -156,10 +156,7 @@ func newTopicStreamReaderStopped(
 		rawMessagesFromBuffer: make(chan rawtopicreader.ServerMessage, 1),
 	}
 
-	res.backgroundWorkers = *background.NewWorker(stopPump, fmt.Sprintf(
-		"topic-reader-stream-background: %v",
-		res.readerID,
-	))
+	res.backgroundWorkers = *background.NewWorker(stopPump, "topic-reader-stream-background")
 
 	res.committer = newCommitterStopped(cfg.Trace, labeledContext, cfg.CommitMode, res.send, res.readerID)
 	res.committer.BufferTimeLagTrigger = cfg.CommitterBatchTimeLag

internal/topic/topicwriterinternal/writer_single_stream.go

@@ -84,10 +84,10 @@ func newSingleStreamWriterStopped(
 ) *SingleStreamWriter {
 	return &SingleStreamWriter{
 		cfg: cfg,
-		background: *background.NewWorker(xcontext.ValueOnly(ctxForPProfLabelsOnly), fmt.Sprintf(
-			"ydb-topic-stream-writer-background: %v",
-			cfg.reconnectorInstanceID,
-		)),
+		background: *background.NewWorker(
+			xcontext.ValueOnly(ctxForPProfLabelsOnly),
+			"ydb-topic-stream-writer-background",
+		),
 		closeCompleted: make(empty.Chan),
 	}
 }