[KAFKA-9293] NPE in DumpLogSegments with --offsets-decoder

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.4.1
• Assignee: Jason Gustafson
• Reporter: Jason Gustafson
• Created: 11/Dec/19 19:34
• Updated: 03/Jan/20 21:13
• Resolved: 03/Jan/20 21:13

Description

Exception in thread "main" java.lang.NullPointerException
        at org.apache.kafka.common.utils.Utils.toArray(Utils.java:230)
        at kafka.tools.DumpLogSegments$OffsetsMessageParser.$anonfun$parseGroupMetadata$2(DumpLogSegments.scala:287)
        at kafka.tools.DumpLogSegments$OffsetsMessageParser.parseGroupMetadata(DumpLogSegments.scala:284)
        at kafka.tools.DumpLogSegments$OffsetsMessageParser.parse(DumpLogSegments.scala:317)
        at kafka.tools.DumpLogSegments$.$anonfun$dumpLog$2(DumpLogSegments.scala:372)
        at kafka.tools.DumpLogSegments$.$anonfun$dumpLog$2$adapted(DumpLogSegments.scala:343)
        at scala.collection.Iterator.foreach(Iterator.scala:941)
        at scala.collection.Iterator.foreach$(Iterator.scala:941)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
        at scala.collection.IterableLike.foreach(IterableLike.scala:74)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
        at kafka.tools.DumpLogSegments$.$anonfun$dumpLog$1(DumpLogSegments.scala:343)
        at kafka.tools.DumpLogSegments$.$anonfun$dumpLog$1$adapted(DumpLogSegments.scala:340)
        at scala.collection.Iterator.foreach(Iterator.scala:941)
        at scala.collection.Iterator.foreach$(Iterator.scala:941)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
        at scala.collection.IterableLike.foreach(IterableLike.scala:74)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
        at kafka.tools.DumpLogSegments$.dumpLog(DumpLogSegments.scala:340)
        at kafka.tools.DumpLogSegments$.$anonfun$main$1(DumpLogSegments.scala:60)
        at kafka.tools.DumpLogSegments$.main(DumpLogSegments.scala:51)
        at kafka.tools.DumpLogSegments.main(DumpLogSegments.scala)

The problem is that "userData" is nullable, but the dump log tool doesn't check for null.

Issue Links

• links to: GitHub Pull Request #7820