search

Yolean / kafka-keyvalue

The sequel to https://github.com/Yolean/kafka-cache - over HTTP this time
Apache License 2.0
3 stars 4 forks source link

NPE when started without --onupdate #2

Open solsson opened 5 years ago

solsson commented 5 years ago

Startup fails when there's no onupdate URL.

solsson commented 5 years ago 
cache1_1                 | java.lang.NullPointerException
cache1_1                 |  at se.yolean.kafka.keyvalue.KeyvalueUpdateProcessor.process(KeyvalueUpdateProcessor.java:128)
cache1_1                 |  at se.yolean.kafka.keyvalue.KeyvalueUpdateProcessor.process(KeyvalueUpdateProcessor.java:122)
cache1_1                 |  at se.yolean.kafka.keyvalue.KeyvalueUpdateProcessor.process(KeyvalueUpdateProcessor.java:22)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:115)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:146)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:129)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:93)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:84)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:351)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.AssignedStreamsTasks.process(AssignedStreamsTasks.java:104)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.TaskManager.process(TaskManager.java:413)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:862)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:777)
cache1_1                 |  at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:747)