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

    • Bug
    • Resolution: Done
    • Blocker
    • Camel-K-GA
    • None
    • Camel-K
    • None
    • False
    • False
    • % %
    • Undefined
    • 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

          blocks

          Bug - A problem that impairs or prevents the functions of the product. ENTESB-16879 AWS-Kinesis kamelet NoClassDefFoundError: com/fasterxml/jackson/annotation/JsonKey

          • Blocker - To be worked above all other priorities. This term is chosen when the severity of the issue is very high, has no workaround, or the effort for the change is comparatively low. Issues that may be very publicly visible and could generate significant media attention may also drive a higher priority.
          • Done

          Activity

            People

              acosenti Andrea Cosentino
              lfabriko@redhat.com Lucie Krejcirova
              Lucie Krejcirova Lucie Krejcirova
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: