diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
index 8029b4ae60..5f17172e51 100644
--- a/flow/connectors/postgres/cdc.go
+++ b/flow/connectors/postgres/cdc.go
@@ -246,6 +246,7 @@ func (p *PostgresCDCSource) consumeStream(
 	shutdown := utils.HeartbeatRoutine(p.ctx, func() string {
 		jobName := p.flowJobName
 		currRecords := cdcRecordsStorage.Len()
+		p.logger.Info(fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords))
 		return fmt.Sprintf("pulling records for job - %s, currently have %d records", jobName, currRecords)
 	})
 	defer shutdown()