Hexa
03/07/2019, 7:13 PM// event: List<KinesisEvent.KinesisEventRecord>
event.records.forEach {
try {
val putRecordsRequest = PutRecordsRequest()
putRecordsRequest.streamName = "test-stream"
val putRecordsRequestEntryList = ArrayList<PutRecordsRequestEntry>()
for (i in 0..499) {
val putRecordsRequestEntry = PutRecordsRequestEntry()
putRecordsRequestEntry.data = it.kinesis.data
putRecordsRequestEntry.partitionKey = it.kinesis.partitionKey
putRecordsRequestEntryList.add(putRecordsRequestEntry)
}
putRecordsRequest.setRecords(putRecordsRequestEntryList)
val putRecordsResult = kinesisClient.putRecords(putRecordsRequest)
} catch (e: InterruptedException) {
//log error here
}