source-mongodb: adjust logging

Reduces some of the logging noise by adjusting logs to debug level, and makes the frequency of
change stream progress updates 5 minutes instead of 1 minute.

source-mongodb/backfill.go

@@ -141,7 +141,7 @@ func (c *capture) doBackfill(
 		"collection":         binding.resource.Collection,
 		"estimatedTotalDocs": estimatedTotalDocs,
 	})
-	logEntry.Info("starting backfill for collection")
+	logEntry.Debug("starting backfill for collection")
 
 	// By not specifying a sort parameter, MongoDB uses natural sort to order documents. Natural
 	// sort is approximately insertion order (but not guaranteed). We hint to MongoDB to use the _id

source-mongodb/change_stream.go

@@ -137,7 +137,7 @@ func (c *capture) initializeStreams(
 			return nil, fmt.Errorf("initializing change stream on database %q: %w", db, err)
 		}
 
-		logEntry.Info("intialized change stream")
+		logEntry.Debug("intialized change stream")
 
 		out = append(out, changeStream{
 			ms: ms,
@@ -236,9 +236,9 @@ func (c *capture) streamCatchup(
 
 			ts := time.Now()
 			logEntry := log.WithField("database", s.db)
-			logEntry.Info("started catching up stream for database")
+			logEntry.Debug("started catching up stream for database")
 			defer func() {
-				logEntry.WithField("took", time.Since(ts).String()).Info("finished catching up stream for database")
+				logEntry.WithField("took", time.Since(ts).String()).Debug("finished catching up stream for database")
 			}()
 
 			if err := c.tryStream(groupCtx, s, &opTime); err != nil {
@@ -273,7 +273,7 @@ func (c *capture) tryStream(
 			log.WithFields(log.Fields{
 				"database":         s.db,
 				"eventClusterTime": ev.ClusterTime,
-			}).Info("catch up stream reached cluster OpTime high watermark")
+			}).Debug("catch up stream reached cluster OpTime high watermark")
 			// Early return without a checkpoint for the "post batch resume token", since by
 			// definition we have received a document that corresponds to a specific resume
 			// token.

source-mongodb/pull.go

@@ -37,7 +37,7 @@ const (
 	// progress report is currently just the count of stream documents that have been processed,
 	// which provides a nice indication in the logs of what the capture is doing when it is reading
 	// change streams.
-	streamLoggerInterval = 1 * time.Minute
+	streamLoggerInterval = 5 * time.Minute
 )
 
 // Pull is a very long lived RPC through which the Flow runtime and a