Update change_stream.go

tdq45gj · tdq45gj · commit e302d9d309e3 · 2024-12-03T09:24:54.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -281,7 +281,6 @@ func (csr *ChangeStreamReader) readAndHandleOneChangeEventBatch(
 		}
 
 		csr.logger.Trace().Msgf("%s received a change event: %v", csr, changeEventBatch[eventsRead])
-		fmt.Printf("%d %d\n", changeEventBatch[eventsRead].ClusterTime.T, changeEventBatch[eventsRead].ClusterTime.I)
 
 		if changeEventBatch[eventsRead].ClusterTime != nil &&
 			(csr.lastChangeEventTime == nil ||

Original file line number	Diff line number	Diff line change
`@@ -281,7 +281,6 @@ func (csr *ChangeStreamReader) readAndHandleOneChangeEventBatch(`
`281`	`281`	`}`
`282`	`282`
`283`	`283`	`csr.logger.Trace().Msgf("%s received a change event: %v", csr, changeEventBatch[eventsRead])`
`284`		`- fmt.Printf("%d %d\n", changeEventBatch[eventsRead].ClusterTime.T, changeEventBatch[eventsRead].ClusterTime.I)`
`285`	`284`
`286`	`285`	`if changeEventBatch[eventsRead].ClusterTime != nil &&`
`287`	`286`	`(csr.lastChangeEventTime == nil \|\|`