kinesis-produce.js

var AWS = require("aws-sdk");

AWS.config.loadFromPath("./config.json");
var kinesis = new AWS.Kinesis();

var params = {
  StreamName: "rch850-stream",
  PartitionKey: i + "",
  Data: new Buffer("oisiiryokucha" + i).toString("base64"),
};

kinesis.putRecord(params, function(err, data) {
  if (err) console.log(err, err.stack);
  else console.log(data);
});