-
Bug
-
Resolution: Done
-
Blocker
-
fuse-next-TP1-CR2
-
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.
- blocks
-
ENTESB-13453 Camel-K-Event-streaming
- Closed
-
ENTESB-13479 Camel-K-Event-streaming
- Closed