From 6126e64758137c58c1ab6ff39a12f9b915b9e2e1 Mon Sep 17 00:00:00 2001 From: Amogh Bharadwaj Date: Thu, 21 Sep 2023 21:15:20 +0530 Subject: [PATCH] Tracking total records in EH connector (#404) - Adds table mapping to Eventhub syncrecords return body for catalog metrics --- flow/connectors/eventhub/eventhub.go | 1 + 1 file changed, 1 insertion(+) diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go index c9a7c7c82c..c54e32b72f 100644 --- a/flow/connectors/eventhub/eventhub.go +++ b/flow/connectors/eventhub/eventhub.go @@ -182,6 +182,7 @@ func (c *EventHubConnector) SyncRecords(req *model.SyncRecordsRequest) (*model.S FirstSyncedCheckPointID: batch.FirstCheckPointID, LastSyncedCheckPointID: batch.LastCheckPointID, NumRecordsSynced: int64(len(batch.Records)), + TableNameRowsMapping: tableNameRowsMapping, }, nil }