From fd7e4d5a4ba1179fd83aff8a9a31bd023b5d7174 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Wed, 13 Mar 2024 21:53:37 +0000 Subject: [PATCH] Log LastOffset when logging start of SyncFlow --- flow/activities/flowable.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go index 17187a35c6..afd7b3704e 100644 --- a/flow/activities/flowable.go +++ b/flow/activities/flowable.go @@ -287,7 +287,6 @@ func (a *FlowableActivity) SyncFlow( } defer connectors.CloseConnector(ctx, dstConn) - logger.Info("pulling records...") tblNameMapping := make(map[string]model.NameAndExclude, len(options.TableMappings)) for _, v := range options.TableMappings { tblNameMapping[v.SourceTableIdentifier] = model.NewNameAndExclude(v.DestinationTableIdentifier, v.Exclude) @@ -315,6 +314,7 @@ func (a *FlowableActivity) SyncFlow( if err != nil { return nil, err } + logger.Info("pulling records...", slog.Int64("LastOffset", lastOffset)) // start a goroutine to pull records from the source recordBatch := model.NewCDCRecordStream()