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

[camel-event-streaming example] Broken unmarshaling on CR2

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Blocker Blocker
    • fuse-next-TP1-GA
    • fuse-next-TP1-CR2
    • Camel-K
    • None

      I run CrimeBridge integration from https://github.com/openshift-integration/camel-k-example-event-streaming/blob/master/event-bridge/CrimeBridge.java

      I got the following error on the first consumed message.

      [1] 2020-04-15 10:15:04.523 ERROR [Camel (camel-k) thread #2 - KafkaConsumer[crime-data]] DefaultErrorHandler - Failed delivery for (MessageId: ID-crime-bridge-6b889797dd-qpvt7-1586945704494-0-1 on ExchangeId: ID-crime-bridge-6b889797dd-qpvt7-1586945704494-0-1). Exhausted after delivery attempt: 1 caught: java.lang.NullPointerException
      [1] 
      [1] Message History (complete message history is disabled)
      [1] ---------------------------------------------------------------------------------------------------------------------------------------
      [1] RouteId              ProcessorId          Processor                                                                        Elapsed (ms)
      [1] [route1            ] [route1            ] [from[kafka://crime-data?brokers=event-streaming-kafka-cluster-kafka-bootstrap.] [        62]
      [1]     ...
      [1] [route1            ] [unmarshal1        ] [unmarshal[org.apache.camel.model.dataformat.JsonDataFormat@33634f04]          ] [         0]
      [1] 
      [1] Stacktrace
      [1] ---------------------------------------------------------------------------------------------------------------------------------------
      [1] java.lang.NullPointerException: null
      [1]     at org.joor.Compile$ByteArrayClassLoader.findClass(Compile.java:172) ~[org.jooq.joor-0.9.12.jar:?]
      [1]     at java.lang.ClassLoader.findClass(ClassLoader.java:751) ~[?:?]
      [1]     at java.lang.ClassLoader.loadClass(ClassLoader.java:633) ~[?:?]
      [1]     at java.lang.Package.getPackageInfo(Package.java:420) ~[?:?]
      [1]     at java.lang.Package.getAnnotation(Package.java:441) ~[?:?]
      [1]     at com.fasterxml.jackson.module.jaxb.JaxbAnnotationIntrospector.findAnnotation(JaxbAnnotationIntrospector.java:1291) ~[com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.module.jaxb.JaxbAnnotationIntrospector.findAccessType(JaxbAnnotationIntrospector.java:571) ~[com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.module.jaxb.JaxbAnnotationIntrospector.findAutoDetectVisibility(JaxbAnnotationIntrospector.java:522) ~[com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.introspect.AnnotationIntrospectorPair.findAutoDetectVisibility(AnnotationIntrospectorPair.java:212) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.cfg.MapperConfigBase.getDefaultVisibilityChecker(MapperConfigBase.java:700) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.introspect.POJOPropertiesCollector.<init>(POJOPropertiesCollector.java:142) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.introspect.BasicClassIntrospector.constructPropertyCollector(BasicClassIntrospector.java:212) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.introspect.BasicClassIntrospector.collectProperties(BasicClassIntrospector.java:190) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.introspect.BasicClassIntrospector.forDeserialization(BasicClassIntrospector.java:112) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.introspect.BasicClassIntrospector.forDeserialization(BasicClassIntrospector.java:16) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.DeserializationConfig.introspect(DeserializationConfig.java:804) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.deser.DeserializerCache._createDeserializer(DeserializerCache.java:324) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.deser.DeserializerCache._createAndCache2(DeserializerCache.java:264) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.deser.DeserializerCache._createAndCacheValueDeserializer(DeserializerCache.java:244) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.deser.DeserializerCache.findValueDeserializer(DeserializerCache.java:142) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.DeserializationContext.findRootValueDeserializer(DeserializationContext.java:476) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.ObjectMapper._findRootDeserializer(ObjectMapper.java:4389) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4198) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3242) ~[com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:2.10.2]
      [1]     at org.apache.camel.component.jackson.JacksonDataFormat.unmarshal(JacksonDataFormat.java:202) ~[org.apache.camel.camel-jackson-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.support.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:64) ~[org.apache.camel.camel-support-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:396) [org.apache.camel.camel-base-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:153) [org.apache.camel.camel-base-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60) [org.apache.camel.camel-base-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147) [org.apache.camel.camel-base-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:286) [org.apache.camel.camel-base-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:84) [org.apache.camel.camel-base-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:40) [org.apache.camel.camel-support-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.doRun(KafkaConsumer.java:346) [org.apache.camel.camel-kafka-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:222) [org.apache.camel.camel-kafka-3.1.0.fuse-jdk11-800010-redhat-00002.jar:3.1.0.fuse-jdk11-800010-redhat-00002]
      [1]     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
      [1]     at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
      [1]     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
      [1]     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
      [1]     at java.lang.Thread.run(Thread.java:834) [?:?]
      

      The bridge was working on previous builds.

              lburgazz@redhat.com Luca Burgazzoli
              jbouska@redhat.com Jan Bouska
              Jan Bouska Jan Bouska
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: