[
https://issues.apache.org/jira/browse/KAFKA-897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13652087#comment-13652087
]
Jun Rao commented on KAFKA-897:
-------------------------------
Ok. So the confusing part is that the comment in the code is inaccurate. We
actually explicitly store the size of the value in the binary representation.
So we should change 6. in the above comment to the following:
* 6. 4 byte payload length, containing length V
* 7. V byte payload
Colin,
It seems that our code only allows null key/value in trunk. So, we can fix this
in trunk. It seems that ConsumerIterator is already fixed in trunk. For the
changes in DefaultMessageFormatter, could you verify if
FilterOutputStream.write() supports null input? If so, we don't need to patch
it either.
> NullPointerException in ConsoleConsumer
> ---------------------------------------
>
> Key: KAFKA-897
> URL: https://issues.apache.org/jira/browse/KAFKA-897
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 0.8
> Reporter: Colin B.
> Assignee: Neha Narkhede
> Priority: Minor
> Attachments: Kafka897-v1.patch
>
>
> The protocol document [1] mentions that keys and values in message sets can
> be null. However the ConsoleConsumer throws a NPE when a null is passed for
> the value.
> java.lang.NullPointerException
> at kafka.utils.Utils$.readBytes(Utils.scala:141)
> at
> kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:106)
> at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
> at
> kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:61)
> at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:53)
> at scala.collection.Iterator$class.foreach(Iterator.scala:631)
> at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
> at kafka.consumer.KafkaStream.foreach(KafkaStream.scala:25)
> at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:195)
> at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
> [1]
> https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Messagesets
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
