[jira] [Commented] (KAFKA-2833) OffsetsMessageFormatter hits unexpected exception

["Guozhang Wang (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15004580#comment-15004580 ] 

Guozhang Wang commented on KAFKA-2833:
--------------------------------------

I missed in while doing KAFKA-2017, my bad. Submitting a fix below.

> OffsetsMessageFormatter hits unexpected exception
> -------------------------------------------------
>
>                 Key: KAFKA-2833
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2833
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jun Rao
>            Assignee: Guozhang Wang
>             Fix For: 0.9.0.0
>
>
> Add the following property to config/consumer.properties 
> exclude.internal.topics=false
> bin/kafka-console-consumer.sh --consumer.config config/consumer.properties --from-beginning --topic __consumer_offsets --zookeeper localhost:2181 --formatter "kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter"
> Processed a total of 1 messages
> [2015-11-13 09:17:06,376] ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$)
> org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'metadata': java.nio.BufferUnderflowException
> 	at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
> 	at kafka.coordinator.GroupMetadataManager$.kafka$coordinator$GroupMetadataManager$$readOffsetMessageValue(GroupMetadataManager.scala:861)
> 	at kafka.coordinator.GroupMetadataManager$OffsetsMessageFormatter.writeTo(GroupMetadataManager.scala:934)
> 	at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:114)
> 	at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:65)
> 	at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:43)
> 	at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)