From 6a9cc9920c7e4ccccb97d9897cfca41e6b6c7a8d Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Tue, 7 Nov 2023 10:41:29 -0500 Subject: [PATCH] add one more useful log --- flow/connectors/eventhub/eventhub.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go index c00e9f0107..f2faccf13a 100644 --- a/flow/connectors/eventhub/eventhub.go +++ b/flow/connectors/eventhub/eventhub.go @@ -178,6 +178,10 @@ func (c *EventHubConnector) processBatch( } } + log.WithFields(log.Fields{ + "flowName": flowJobName, + }).Infof("processed %d records for sending", numRecords) + err := flushBatch() if err != nil { return 0, err