crosscluster/physical: dont perioridically log buffer size by default

msbutler · msbutler · commit e9f420b65986 · 2025-10-24T10:40:38.000-04:00
Epic: none

Release note: none
diff --git a/pkg/crosscluster/physical/stream_ingestion_processor.go b/pkg/crosscluster/physical/stream_ingestion_processor.go
@@ -784,7 +784,7 @@ func (sip *streamIngestionProcessor) handleEvent(event PartitionEvent) error {
 	}
 
 	if sip.logBufferEvery.ShouldLog() {
-		log.Dev.Infof(sip.Ctx(), "current KV batch size %d (%d items)", sip.buffer.curKVBatchSize, len(sip.buffer.curKVBatch))
+		log.VEventf(sip.Ctx(), 2, "current KV batch size %d (%d items)", sip.buffer.curKVBatchSize, len(sip.buffer.curKVBatch))
 	}
 
 	if sip.buffer.shouldFlushOnSize(sip.Ctx(), sv) {

Original file line number	Diff line number	Diff line change
`@@ -784,7 +784,7 @@ func (sip *streamIngestionProcessor) handleEvent(event PartitionEvent) error {`
`784`	`784`	`}`
`785`	`785`
`786`	`786`	`if sip.logBufferEvery.ShouldLog() {`
`787`		`- log.Dev.Infof(sip.Ctx(), "current KV batch size %d (%d items)", sip.buffer.curKVBatchSize, len(sip.buffer.curKVBatch))`
	`787`	`+ log.VEventf(sip.Ctx(), 2, "current KV batch size %d (%d items)", sip.buffer.curKVBatchSize, len(sip.buffer.curKVBatch))`
`788`	`788`	`}`
`789`	`789`
`790`	`790`	`if sip.buffer.shouldFlushOnSize(sip.Ctx(), sv) {`