@@ -159,10 +159,6 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
159159 break
160160 }
161161
162- verifier .logger .Debug ().
163- Stringer ("resumeToken" , cs .ResumeToken ()).
164- Msg ("TryNext got an event!" )
165-
166162 if changeEventBatch == nil {
167163 changeEventBatch = make ([]ParsedEvent , cs .RemainingBatchLength ()+ 1 )
168164 }
@@ -306,9 +302,7 @@ func (verifier *Verifier) StartChangeStream(ctx context.Context) error {
306302 Msg ("Failed to extract timestamp from persisted resume token." )
307303 }
308304
309- logEvent .
310- Interface ("pipeline" , pipeline ).
311- Msg ("Starting change stream from persisted resume token." )
305+ logEvent .Msg ("Starting change stream from persisted resume token." )
312306
313307 opts = opts .SetStartAfter (savedResumeToken )
314308 } else {
@@ -320,7 +314,6 @@ func (verifier *Verifier) StartChangeStream(ctx context.Context) error {
320314 return errors .Wrap (err , "failed to start session" )
321315 }
322316 sctx := mongo .NewSessionContext (ctx , sess )
323- verifier .logger .Debug ().Interface ("pipeline" , pipeline ).Msg ("Opened change stream." )
324317 srcChangeStream , err := verifier .srcClient .Watch (sctx , pipeline , opts )
325318 if err != nil {
326319 return errors .Wrap (err , "failed to open change stream" )
0 commit comments