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)
