[jira] [Created] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

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

huxihx created KAFKA-6592:
-----------------------------

             Summary: NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`
                 Key: KAFKA-6592
                 URL: https://issues.apache.org/jira/browse/KAFKA-6592
             Project: Kafka
          Issue Type: Bug
          Components: tools
    Affects Versions: 1.0.0
            Reporter: huxihx


When reading streams app's output topic with WindowedDeserializer deserilizer using kafka-console-consumer.sh, NullPointerException was thrown due to the fact that the inner deserializer was not initialized since there is no place in ConsoleConsumer to set this class.

Complete stack trace is shown below:
{code:java}
[2018-02-26 14:56:04,736] ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$)

java.lang.NullPointerException

at org.apache.kafka.streams.kstream.internals.WindowedDeserializer.deserialize(WindowedDeserializer.java:89)

at org.apache.kafka.streams.kstream.internals.WindowedDeserializer.deserialize(WindowedDeserializer.java:35)

at kafka.tools.DefaultMessageFormatter.$anonfun$writeTo$2(ConsoleConsumer.scala:544)

at scala.Option.map(Option.scala:146)

at kafka.tools.DefaultMessageFormatter.write$1(ConsoleConsumer.scala:545)

at kafka.tools.DefaultMessageFormatter.writeTo(ConsoleConsumer.scala:560)

at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:147)

at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:84)

at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:54)

at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)