NPE in KafkaFlowForwarder

2020-04-12T04:33:08,077 | ERROR | Camel (sinkServer) thread #109 - JmsConsumer[OpenNMS.Sink.Telemetry-Netflow-5] | KafkaFlowForwarder               | 266 - org.opennms.features.flows.kafka-persistence - 26.1.0.SNAPSHOT | Exception while sending flow to kafka.
java.lang.NullPointerException: null
        at org.opennms.netmgt.flows.persistence.model.NodeInfo$Builder.setForeginId(NodeInfo.java:729) ~[?:?]
        at org.opennms.netmgt.flows.persistence.FlowDocumentBuilder.buildNodeInfo(FlowDocumentBuilder.java:210) ~[?:?]
        at org.opennms.netmgt.flows.persistence.FlowDocumentBuilder.buildFlowDocument(FlowDocumentBuilder.java:105) ~[?:?]
        at org.opennms.netmgt.flows.persistence.KafkaFlowForwarder.forward(KafkaFlowForwarder.java:79) ~[?:?]
        at Proxy3aef1421_35be_41d5_af54_a60cc19ef11b.forward(Unknown Source) ~[?:?]
        at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?]
        at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
        at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1654) ~[?:?]
        at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?]
        at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?]
        at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?]
        at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?]
        at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
        at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497) ~[?:?]
        at org.opennms.netmgt.flows.elastic.ElasticFlowRepository.persist(ElasticFlowRepository.java:249) ~[?:?]