kinesis-put-records.js

const { KinesisClient, PutRecordsCommand } = require("@aws-sdk/client-kinesis");

const kinesisClient = new KinesisClient({
    region: "eu-central-1"
});

(async function() {

    const recordData = [
        {
            Data: Buffer.from(JSON.stringify({
                name: "cta-clicked",
                time: new Date()
            })),
            PartitionKey: 'SERVICE_NAME' // Must be a string.
        }
    ]
    const data = await kinesisClient.send(new PutRecordsCommand({
        Records: recordData,
        StreamName: 'events'
    }));
    console.log(data)

})()