| // camel-k: dependency=camel-aws-kinesis dependency=camel-base64 | |
| // | |
| // Apache Camel Kinesis Consumer | |
| // | |
| // Typical data when using cbor looks like this: | |
| // {"sequenceNumber":"1222","approximateArrivalTimestamp":1123,"data":"SGVsbG8gQ2FtZWwgSw==","partitionKey":"p-01123"...} | |
| // | |
| // 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}') |