Hexa
03/07/2019, 7:20 PMkinesisEvent.records.asSequence()
before calling foreach in this example: // 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
}
sitepodmatt
03/07/2019, 7:23 PMAlowaniak
03/07/2019, 8:35 PMMike
03/08/2019, 12:20 AM