> 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.

Attachment: signature.asc
Description: Message signed with OpenPGP using GPGMail

Reply via email to