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

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 1.0.0
• Component/s: streams, tools
• Assignee: huxihx
• Reporter: huxihx
• Created: 26/Feb/18 07:07
• Updated: 01/Mar/19 21:53
• Resolved: 01/Mar/19 21:53

Description

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:

[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)

Issue Links

• Is contained by: KAFKA-4831 Extract WindowedSerde to public APIs
• links to: GitHub Pull Request #4797
• links to: GitHub Pull Request #4864
• links to: KIP-265