From 75d4ce9cc70788c2af8ab29729c0f4b2249360c2 Mon Sep 17 00:00:00 2001 From: ravikiran-s Date: Wed, 3 May 2023 20:46:13 +0530 Subject: [PATCH] fix --- clientlibrary/streams/dynamodb_adapter_client.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/clientlibrary/streams/dynamodb_adapter_client.go b/clientlibrary/streams/dynamodb_adapter_client.go index 5e38268..03c0387 100644 --- a/clientlibrary/streams/dynamodb_adapter_client.go +++ b/clientlibrary/streams/dynamodb_adapter_client.go @@ -296,7 +296,8 @@ func (d DynamodbStreamAdapterClient) convertGetRecordsInput(params *kinesis.GetR } func (d DynamodbStreamAdapterClient) convertGetRecordsOutput(dynamoOutput *dynamodbstreams.GetRecordsOutput) *kinesis.GetRecordsOutput { - kinesisOutput := kinesis.GetRecordsOutput{} + var millisBehindLatest = time.Now().UnixMilli() + kinesisOutput := kinesis.GetRecordsOutput{MillisBehindLatest: &millisBehindLatest, Records: make([]ktypes.Record, 0)} if dynamoOutput != nil && len(dynamoOutput.Records) != 0 { kinesisOutput.Records = make([]ktypes.Record, 0) kinesisOutput.ResultMetadata = dynamoOutput.ResultMetadata @@ -306,7 +307,7 @@ func (d DynamodbStreamAdapterClient) convertGetRecordsOutput(dynamoOutput *dynam if lastRecord.Dynamodb != nil && lastRecord.Dynamodb.ApproximateCreationDateTime != nil { lastRecordCreateTime = lastRecord.Dynamodb.ApproximateCreationDateTime } - millisBehindLatest := int64(math.Max(float64(time.Now().Sub(*lastRecordCreateTime).Milliseconds()), float64(0))) + millisBehindLatest = int64(math.Max(float64(time.Now().Sub(*lastRecordCreateTime).Milliseconds()), float64(0))) kinesisOutput.MillisBehindLatest = &millisBehindLatest } for _, record := range dynamoOutput.Records {