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 {