fix lint, log to debug

Author: heavycrystal

flow/connectors/mysql/cdc.go

@@ -388,7 +388,7 @@ func (c *MySqlConnector) PullRecords(
 					// reset timeoutCtx to a low value and wait for inTx to become false
 					// cancelTimeout should be called by defer, spurious lint
 					cancelTimeout()
-					//nolint
+					//nolint:govet
 					timeoutCtx, cancelTimeout = context.WithTimeout(ctx, 10*time.Second)
 					overtime = true
 				} else {
@@ -407,7 +407,7 @@ func (c *MySqlConnector) PullRecords(
 		if err != nil {
 			if errors.Is(err, context.DeadlineExceeded) {
 				if !inTx {
-					//nolint
+					//nolint:govet
 					return nil
 				}
 				// if in tx, don't let syncer exit due to deadline exceeded
@@ -492,7 +492,8 @@ func (c *MySqlConnector) PullRecords(
 							if schemaIdx == -1 {
 								if !skewLossReported {
 									skewLossReported = true
-									c.logger.Warn("Unknown column name received, ignoring", slog.String("name", string(ev.Table.ColumnName[idx])))
+									c.logger.Warn("Unknown column name received, ignoring",
+										slog.String("name", string(ev.Table.ColumnName[idx])))
 								}
 							} else {
 								return schema.Columns[schemaIdx]

flow/connectors/postgres/cdc.go

@@ -709,7 +709,7 @@ func processMessage[Items model.Items](
 
 		return processRelationMessage[Items](ctx, p, currentClientXlogPos, msg)
 	case *pglogrepl.LogicalDecodingMessage:
-		logger.Info("LogicalDecodingMessage",
+		logger.Debug("LogicalDecodingMessage",
 			slog.Bool("Transactional", msg.Transactional),
 			slog.String("Prefix", msg.Prefix),
 			slog.String("LSN", msg.LSN.String()))