-
Notifications
You must be signed in to change notification settings - Fork 71
Closed
Description
Describe the bug
Using the SSE Kafka proxy I am getting a null pointer exception when the heaers are null
org.agrona.concurrent.AgentTerminationException: java.lang.NullPointerException: Cannot invoke "io.aklivity.zilla.runtime.binding.sse.kafka.internal.types.Array32FW.matchFirst(java.util.function.Predicate)" because "headers" is null
at io.aklivity.zilla.runtime.engine@0.9.47/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:671)
at org.agrona.core/org.agrona.concurrent.AgentRunner.doDutyCycle(AgentRunner.java:291)
at org.agrona.core/org.agrona.concurrent.AgentRunner.run(AgentRunner.java:164)
at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: java.lang.NullPointerException: Cannot invoke "io.aklivity.zilla.runtime.binding.sse.kafka.internal.types.Array32FW.matchFirst(java.util.function.Predicate)" because "headers" is null
at io.aklivity.zilla.runtime.binding.sse.kafka@0.9.47/io.aklivity.zilla.runtime.binding.sse.kafka.internal.stream.SseKafkaProxyFactory$KafkaProxy.onKafkaData(SseKafkaProxyFactory.java:657)
at io.aklivity.zilla.runtime.binding.sse.kafka@0.9.47/io.aklivity.zilla.runtime.binding.sse.kafka.internal.stream.SseKafkaProxyFactory$KafkaProxy.onKafkaMessage(SseKafkaProxyFactory.java:573)
at io.aklivity.zilla.runtime.engine@0.9.47/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.handleReadReply(DispatchAgent.java:1187)
at io.aklivity.zilla.runtime.engine@0.9.47/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.handleRead(DispatchAgent.java:988)
at io.aklivity.zilla.runtime.engine@0.9.47/io.aklivity.zilla.runtime.engine.internal.concurent.ManyToOneRingBuffer.read(ManyToOneRingBuffer.java:181)
at io.aklivity.zilla.runtime.engine@0.9.47/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:665)
... 3 more
Suppressed: java.lang.Exception: [engine/data#0] [0x000000000000000c] streams=[consumeAt=0x0003c660 (0x000000000033c660), produceAt=0x000470b8 (0x00000000003470b8)]
at io.aklivity.zilla.runtime.engine@0.9.47/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:669)
... 3 more
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels