Hi people,

I'm running a Kafka Streams app (trunk build from a few days ago), I see
this error from time to time:

Exception in thread "StreamThread-18" java.lang.NullPointerException

at org.apache.kafka.streams.processor.internals.StreamThread$5.
apply(StreamThread.java:998)
at org.apache.kafka.streams.processor.internals.StreamThread.pe
rformOnAllTasks(StreamThread.java:489)
at org.apache.kafka.streams.processor.internals.StreamThread.
closeAllTasks(StreamThread.java:995)
at org.apache.kafka.streams.processor.internals.StreamThread.sh
utdownTasksAndState(StreamThread.java:442)
at org.apache.kafka.streams.processor.internals.StreamThread.
shutdown(StreamThread.java:387)
at org.apache.kafka.streams.processor.internals.StreamThread.
run(StreamThread.java:368)


After that it spews a bunch of these:

Exception in thread "StreamThread-13" java.lang.IllegalStateException:
Incorrect state transition from RUNNING to NOT_RUNNING

at org.apache.kafka.streams.processor.internals.StreamThread.
setState(StreamThread.java:163)
at org.apache.kafka.streams.processor.internals.StreamThread.
shutdown(StreamThread.java:416)

I'm now running on multiple instances, before I ran on a single instance, I
don't think I saw it then.

regards, Frank

Reply via email to