04-aws-kinesis-source-basic/aws-kinesis-consumer.groovy

// camel-k: dependency=camel-aws-kinesis dependency=camel-base64
//
// Apache Camel Kinesis Consumer
//

// So we unmarshal it, extract the data element which is in base64 format and decode it
from('knative:channel/aws-kinesis')
    .unmarshal()
        .json()
    .setBody { it.in.body.data }
    .unmarshal()
        .base64()
    .log('Received: ${body}')