in web/js/producer.js [527:563]
function createDataConstant() {
console.log("Creating data using constant rate")
var maxRecordsTotal = 500,
records = [];
//clean up line breaks, and handle older timestamp template format
var template = getCleanedTemplate();
for(var n = 0; n < rate; n++) {
var data = faker.fake(template);
if($("#zipped").is(':checked')){
var pako = window.pako;
data = pako.gzip(data);
} else {
data = data + '\n';
}
var record = {
"Data": data
};
if(streamType === "stream"){
record.PartitionKey = (Math.floor(Math.random() * (10000000000))).toString();
}
records.push(record);
if(records.length === maxRecordsTotal){
sendToKinesis(records);
records = [];
}
}
if(records.length > 0){
sendToKinesis(records);
}
$("#recordsSentMessage").text(totalRecordsSent.toString() + " records sent to Kinesis.");
}