For kameletbinding with inmemory channel, following exception occured: oc apply -f messages.yaml oc apply -f aws-k-source.binding.yaml apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: aws-k-source spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: aws-kinesis-source properties: stream: kamelet-sample2 accessKey: xxx secretKey: xxx region: us-west-1 sink: ref: kind: InMemoryChannel apiVersion: messaging.knative.dev/v1beta1 name: messages [1] 2021-05-13 08:16:06,527 INFO [org.apa.cam.k.Runtime] (main) Apache Camel K Runtime 1.7.1.fuse-800003-redhat-00001 [1] 2021-05-13 08:16:06,531 INFO [org.apa.cam.qua.cor.CamelBootstrapRecorder] (main) bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime [1] 2021-05-13 08:16:06,593 INFO [org.apa.cam.k.lis.SourcesConfigurer] (main) Loading routes from: SourceDefinition{name='aws-kinesis-source', language='yaml', type='template', propertyNames='[accessKey, region, secretKey, stream]', location='file:/etc/camel/sources/aws-kinesis-source.yaml', } [1] 2021-05-13 08:16:06,617 INFO [org.apa.cam.k.lis.SourcesConfigurer] (main) Loading routes from: SourceDefinition{name='camel-k-embedded-flow', language='yaml', location='file:/etc/camel/sources/camel-k-embedded-flow.yaml', } [1] 2021-05-13 08:16:07,374 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes startup summary (total:2 started:2) [1] 2021-05-13 08:16:07,375 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started route1 (kamelet://aws-kinesis-source/source) [1] 2021-05-13 08:16:07,375 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started source (aws2-kinesis://kamelet-sample2) [1] 2021-05-13 08:16:07,375 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.9.0.fuse-800003-redhat-00002 (camel-1) started in 618ms (build:0ms init:223ms start:395ms) [1] 2021-05-13 08:16:07,466 INFO [io.quarkus] (main) camel-k-integration 1.4.0 on JVM (powered by Quarkus 1.11.6.Final-redhat-00001) started in 1.899s. Listening on: http://0.0.0.0:8080 [1] 2021-05-13 08:16:07,466 INFO [io.quarkus] (main) Profile prod activated. [1] 2021-05-13 08:16:07,466 INFO [io.quarkus] (main) Installed features: [camel-attachments, camel-aws2-commons, camel-aws2-kinesis, camel-bean, camel-core, camel-k-cloudevents, camel-k-core, camel-k-knative, camel-k-knative-producer, camel-k-loader-yaml, camel-k-runtime, camel-kamelet, camel-platform-http, camel-support-common, camel-support-commons-logging, camel-yaml-dsl, cdi, mutiny, smallrye-context-propagation, vertx, vertx-web] [1] 2021-05-13 08:16:09,262 ERROR [org.apa.cam.pro.err.DefaultErrorHandler] (Camel (camel-1) thread #0 - aws2-kinesis://kamelet-sample2) Failed delivery for (MessageId: 1138F8F2247C7AB-0000000000000000 on ExchangeId: 1138F8F2247C7AB-0000000000000000). Exhausted after delivery attempt: 1 caught: org.apache.camel.InvalidPayloadException: No body available of type: byte[] but has value: Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123) of type: software.amazon.awssdk.services.kinesis.model.Record on: Message. Caused by: No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123). Exchange[1138F8F2247C7AB-0000000000000000]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123)] [1] [1] Message History (complete message history is disabled) [1] --------------------------------------------------------------------------------------------------------------------------------------- [1] RouteId ProcessorId Processor Elapsed (ms) [1] [source ] [source ] [from[aws2-kinesis://kamelet-sample2?accessKey=RAW(xxx)®ion] [ 11] [1] ... [1] [route1 ] [to1 ] [knative:channel/messages?apiVersion=messaging.knative.dev%2Fv1beta1&kind=InMem] [ 0] [1] [1] Stacktrace [1] --------------------------------------------------------------------------------------------------------------------------------------- [1] : org.apache.camel.InvalidPayloadException: No body available of type: byte[] but has value: Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123) of type: software.amazon.awssdk.services.kinesis.model.Record on: Message. Caused by: No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123). Exchange[1138F8F2247C7AB-0000000000000000]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123)] [1] at org.apache.camel.support.MessageSupport.getMandatoryBody(MessageSupport.java:124) [1] at org.apache.camel.component.knative.http.KnativeHttpProducer.process(KnativeHttpProducer.java:83) [1] at org.apache.camel.processor.Pipeline$PipelineTask.run(Pipeline.java:107) [1] at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181) [1] at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:62) [1] at org.apache.camel.processor.Pipeline.process(Pipeline.java:167) [1] at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:388) [1] at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.processBatch(Kinesis2Consumer.java:109) [1] at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.poll(Kinesis2Consumer.java:73) [1] at org.apache.camel.support.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:190) [1] at org.apache.camel.support.ScheduledPollConsumer.run(ScheduledPollConsumer.java:107) [1] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [1] at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [1] at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [1] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [1] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [1] at java.base/java.lang.Thread.run(Thread.java:829) [1] Caused by: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123) [1] at org.apache.camel.impl.converter.CoreTypeConverterRegistry.mandatoryConvertTo(CoreTypeConverterRegistry.java:275) [1] at org.apache.camel.support.MessageSupport.getMandatoryBody(MessageSupport.java:122) [1] ... 16 more [1] [1] 2021-05-13 08:16:09,264 WARN [org.apa.cam.com.aws.kin.Kinesis2Consumer] (Camel (camel-1) thread #0 - aws2-kinesis://kamelet-sample2) Error processing exchange. Exchange[1138F8F2247C7AB-0000000000000000]. Caused by: [org.apache.camel.InvalidPayloadException - No body available of type: byte[] but has value: Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123) of type: software.amazon.awssdk.services.kinesis.model.Record on: Message. Caused by: No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123). Exchange[1138F8F2247C7AB-0000000000000000]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123)]]: org.apache.camel.InvalidPayloadException: No body available of type: byte[] but has value: Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123) of type: software.amazon.awssdk.services.kinesis.model.Record on: Message. Caused by: No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123). Exchange[1138F8F2247C7AB-0000000000000000]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123)] [1] at org.apache.camel.support.MessageSupport.getMandatoryBody(MessageSupport.java:124) [1] at org.apache.camel.component.knative.http.KnativeHttpProducer.process(KnativeHttpProducer.java:83) [1] at org.apache.camel.processor.Pipeline$PipelineTask.run(Pipeline.java:107) [1] at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181) [1] at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:62) [1] at org.apache.camel.processor.Pipeline.process(Pipeline.java:167) [1] at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:388) [1] at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.processBatch(Kinesis2Consumer.java:109) [1] at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.poll(Kinesis2Consumer.java:73) [1] at org.apache.camel.support.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:190) [1] at org.apache.camel.support.ScheduledPollConsumer.run(ScheduledPollConsumer.java:107) [1] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [1] at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [1] at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [1] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [1] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [1] at java.base/java.lang.Thread.run(Thread.java:829) [1] Caused by: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: software.amazon.awssdk.services.kinesis.model.Record to the required type: byte[] with value Record(SequenceNumber=49618209460110532554388646640940360286141384023762534402, ApproximateArrivalTimestamp=2021-05-13T06:41:48.810Z, Data=SdkBytes(bytes=0xb5eb2d75ab5a), PartitionKey=123) [1] at org.apache.camel.impl.converter.CoreTypeConverterRegistry.mandatoryConvertTo(CoreTypeConverterRegistry.java:275) [1] at org.apache.camel.support.MessageSupport.getMandatoryBody(MessageSupport.java:122) [1] ... 16 more [1]