diff --git a/lib/handlers/blueprints/cw-log-firehose-processor.js b/lib/handlers/blueprints/cw-log-firehose-processor.js index bcc422a0..8c183ad9 100644 --- a/lib/handlers/blueprints/cw-log-firehose-processor.js +++ b/lib/handlers/blueprints/cw-log-firehose-processor.js @@ -37,7 +37,7 @@ function processRecords(records, transformFn) { recordId: recId, }; } else if (data.messageType === 'DATA_MESSAGE') { - const joinedData = data.logEvents.map((e) => transformFn(e)).join(''); + const joinedData = data.logEvents.map((e) => transformFn(e)).join('\n'); const encodedData = Buffer.from(joinedData, 'utf-8').toString('base64'); return { data: encodedData,