fix linter

Author: rekby

internal/topic/topicreaderinternal/committer.go

@@ -52,7 +52,12 @@ type committer struct {
 	commits CommitRanges
 }
 
-func newCommitterStopped(tracer *trace.Topic, lifeContext context.Context, mode PublicCommitMode, send sendMessageToServerFunc, readerID int64) *committer { //nolint:lll,revive
+func newCommitterStopped(
+	tracer *trace.Topic,
+	lifeContext context.Context, //nolint:revive
+	mode PublicCommitMode,
+	send sendMessageToServerFunc,
+) *committer {
 	res := &committer{
 		mode:             mode,
 		clock:            clockwork.NewRealClock(),

internal/topic/topicreaderinternal/committer_test.go

@@ -379,7 +379,7 @@ func TestCommitterBuffer(t *testing.T) {
 func newTestCommitter(ctx context.Context, t testing.TB) *committer {
 	res := newCommitterStopped(&trace.Topic{}, ctx, CommitModeAsync, func(msg rawtopicreader.ClientMessage) error {
 		return nil
-	}, -1)
+	})
 	res.Start()
 	t.Cleanup(func() {
 		if err := res.Close(ctx, errors.New("test committer closed")); err != nil {

internal/topic/topicreaderinternal/stream_reader_impl.go

@@ -158,7 +158,7 @@ func newTopicStreamReaderStopped(
 
 	res.backgroundWorkers = *background.NewWorker(stopPump, "topic-reader-stream-background")
 
-	res.committer = newCommitterStopped(cfg.Trace, labeledContext, cfg.CommitMode, res.send, res.readerID)
+	res.committer = newCommitterStopped(cfg.Trace, labeledContext, cfg.CommitMode, res.send)
 	res.committer.BufferTimeLagTrigger = cfg.CommitterBatchTimeLag
 	res.committer.BufferCountTrigger = cfg.CommitterBatchCounterTrigger
 	res.sessionController.init()