in cdk/lambda/add-approximate-arrival-time.js [18:25]
function enrichPayload(record) {
const payload = JSON.parse(Buffer.from(record.data, 'base64').toString('utf8'));
const timestamp = new Date(record.kinesisRecordMetadata.approximateArrivalTimestamp).toISOString();
const enrichedPayload = Object.assign({approximate_arrival_timestamp: timestamp}, payload);
return Buffer.from(JSON.stringify(enrichedPayload)+"\n").toString('base64');
}