Hexa
kinesisEvent.records.asSequence()
// 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
Alowaniak
Mike
A modern programming language that makes developers happier.