better log

flow/connectors/eventhub/eventhub.go

@@ -202,10 +202,14 @@ func (c *EventHubConnector) processBatch(
 		utcMaxTSString = maxTime.UTC().Format(time.RFC3339)
 	}
 
+	// log utcMaxTSString, curTimeUTCSTring, difference in seconds
+	logstmt := fmt.Sprintf("[total] successfully sent %d records to event hub -"+
+		" max ts in utc - %s, current time in utc - %s, difference in seconds - %d",
+		numRecords, utcMaxTSString, time.Now().UTC().Format(time.RFC3339), int(time.Now().UTC().Sub(maxTime).Seconds()))
+
 	log.WithFields(log.Fields{
 		"flowName": flowJobName,
-	}).Infof("[total] successfully sent %d records to event hub - max ts in utc - %s",
-		numRecords, utcMaxTSString)
+	}).Infof(logstmt)
 	return uint32(numRecords), nil
 }