in kinesis-lambda/src/main/java/com/optimize/downstream/lambda/ProcessKinesisRecords.java [127:143]
private ArrayList<TestAdditonalData> getAdditionalData()
{
ArrayList<TestAdditonalData> additionalIOTDataArrayList = new ArrayList();
// Adding extra content to make the message size more than 1 MB.
// The below generated data will be appended/merged with the message coming from Kineisis Stream.
// It is just to demonstrate that if the message size is more than 1MB, we can gzip the message and send it to KinesisFirehose.
for(int i =0;i <5000; i++)
{
TestAdditonalData t = new TestAdditonalData();
t.setDimension_X(getRandomInt(10,1));
t.setDimension_Y(getRandomInt(10,1));
t.setDimension_Z(getRandomInt(10,1));
additionalIOTDataArrayList.add(t);
}
return additionalIOTDataArrayList;
}