def kinesisEventRecordToRecord()

in src/main/scala/com/gu/mobile/content/notifications/Lambda.scala [49:56]


  def kinesisEventRecordToRecord(eventRecord: KinesisEvent.Record): KinesisClientRecord = {
    KinesisClientRecord.builder()
      .sequenceNumber(eventRecord.getSequenceNumber)
      .approximateArrivalTimestamp(eventRecord.getApproximateArrivalTimestamp.toInstant)
      .data(eventRecord.getData())
      .partitionKey(eventRecord.getPartitionKey)
      .encryptionType(EncryptionType.fromValue(eventRecord.getEncryptionType)).build()
  }