From 2b03b2b299f4a2aceb0ab02db385e87d92c88d1f Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Thu, 21 Sep 2023 20:55:09 +0530 Subject: [PATCH] returns table mapping --- 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 }