> On Jun 19, 2017, at 2:02 PM, Andre Eriksson <an...@tcell.io> wrote: > > I then tried implementing my own scheduling that periodically sends/clears > out messages using the ProcessorContext provided to the aforementioned > transform step. However, it seems that when I call forward() from my > scheduler (i.e. not in a process()/punctuate() call), I get a > NullPointerException at ProcessorContextImpl.java:81 > (https://github.com/apache/kafka/blob/0.10.2/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java#L81). > I assume that this is because currentNode() is null outside of > process()/punctuate() calls.
There may be more elegant or direct solutions, but if all else fails you could always consider producing to a topic rather than trying to forward directly, then you don't have to touch the relatively delicate Processor semantics.
signature.asc
Description: Message signed with OpenPGP using GPGMail
