[jira] [Created] (KAFKA-3142) Improve error message in kstreams

["Jay Kreps (JIRA)" <ji...@apache.org>]

Jay Kreps created KAFKA-3142:
--------------------------------

             Summary: Improve error message in kstreams
                 Key: KAFKA-3142
                 URL: https://issues.apache.org/jira/browse/KAFKA-3142
             Project: Kafka
          Issue Type: Improvement
            Reporter: Jay Kreps


If you have a bug in your kstream code the error message could be slightly better.

1. Not sure what the second error about it already being closed is.
2. I recommend we avoid wrapping the exception (at least for runtime exceptions) so it is more clear to the user that the error is coming from their code not ours.

{code}
[2016-01-23 14:40:59,776] ERROR Uncaught error during processing in thread [StreamThread-1]:  (org.apache.kafka.streams.processor.internals.StreamThread:222)
org.apache.kafka.common.KafkaException: java.lang.NullPointerException
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:327)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:220)
Caused by: java.lang.NullPointerException
	at TestKstreamsApi.lambda$0(TestKstreamsApi.java:27)
	at org.apache.kafka.streams.kstream.internals.KStreamMap$KStreamMapProcessor.process(KStreamMap.java:42)
	at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68)
	at org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:324)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:175)
	at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:56)
	at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:170)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:310)
	... 1 more
[2016-01-23 14:40:59,803] ERROR Failed to close a StreamTask #0_0 in thread [StreamThread-1]:  (org.apache.kafka.streams.processor.internals.StreamThread:586)
java.lang.IllegalStateException: This consumer has already been closed.
	at org.apache.kafka.clients.consumer.KafkaConsumer.ensureNotClosed(KafkaConsumer.java:1281)
	at org.apache.kafka.clients.consumer.KafkaConsumer.acquire(KafkaConsumer.java:1292)
	at org.apache.kafka.clients.consumer.KafkaConsumer.assign(KafkaConsumer.java:779)
	at org.apache.kafka.streams.processor.internals.ProcessorStateManager.close(ProcessorStateManager.java:339)
	at org.apache.kafka.streams.processor.internals.AbstractTask.close(AbstractTask.java:95)
	at org.apache.kafka.streams.processor.internals.StreamTask.close(StreamTask.java:306)
	at org.apache.kafka.streams.processor.internals.StreamThread.closeOne(StreamThread.java:584)
	at org.apache.kafka.streams.processor.internals.StreamThread.removeStreamTasks(StreamThread.java:571)
	at org.apache.kafka.streams.processor.internals.StreamThread.shutdown(StreamThread.java:265)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:225)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)