[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16420029#comment-16420029 ]
huxihx commented on KAFKA-6592: ------------------------------- [~guozhang] [KIP-265|https://cwiki.apache.org/confluence/display/KAFKA/KIP-265%3A+Make+Windowed+Serde+to+public+APIs] says: `And in ConsoleConsumer class, add the new StreamsConfigs names into its options: DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS and DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS. ` That's why I thought this KIP would cover this jira. However, I did not find those added confis in `ConsoleConsumer`. Is it as designed? > 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: streams, tools > Affects Versions: 1.0.0 > Reporter: huxihx > Assignee: huxihx > Priority: Minor > > 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)