Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-16432

AWS Kinesis kamelet throws org.apache.camel.NoTypeConversionAvailableException while logging Record

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Done
    • Priority: Blocker
    • Resolution: Done
    • Affects Version/s: None
    • Fix Version/s: Camel-K-GA
    • Component/s: Camel-K
    • Labels:
      None
    • Steps to Reproduce:
      Hide

      on OCP 4.7, camel K 2021-M3 : build#1 - Apache Camel K Runtime 1.7.1.fuse-800003-redhat-00001, linux-client-1.4.0.fuse-800003-redhat-00001

      kamel install --maven-repository=http://nexus.fuse-qe.eng.rdu2.redhat.com/repository/fuse-all --olm-source=camel-k-source
      
      

      Create integration with secret based configuration - then the log contains badly formed String

      ...Body: ??-u?Z???u?Z]

      Or create knative kameletbinding to inmemory channel, then log of integration throws exception when new message is received:

      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)]

       

      Show
      on OCP 4.7, camel K 2021-M3 : build#1 - Apache Camel K Runtime 1.7.1.fuse-800003-redhat-00001, linux-client-1.4.0.fuse-800003-redhat-00001 kamel install --maven-repository=http: //nexus.fuse-qe.eng.rdu2.redhat.com/repository/fuse-all --olm-source=camel-k-source Create integration with secret based configuration - then the log contains badly formed String ...Body: ??-u?Z???u?Z] Or create knative kameletbinding to inmemory channel, then log of integration throws exception when new message is received: 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)]  

      Description

      The integration is created correctly without exception, but I am observing problem with logging obtained message:

      [1] 2021-05-13 08:08:51,019 INFO [info] (Camel (camel-1) thread #0 - aws2-kinesis://kamelet-sample2) Exchange[ExchangePattern: InOnly, BodyType: software.amazon.awssdk.services.kinesis.model.Record, Body: ??-u?Z???u?Z]

      Integration with secret based configuration, region is lowercase "us-west-1":

      from('kamelet:aws-kinesis-source/aws-kinesis-credentials') 
        .to("log:info")

       

      In case of kameletbinding to knative inmemorychannel, see attached log.

       

        Attachments

          Issue Links

            Activity

              People

              Assignee:
              oscerd Andrea Cosentino
              Reporter:
              lfabriko Lucie Krejcirova
              Tester:
              Lucie Krejcirova Lucie Krejcirova
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved: