[
https://issues.apache.org/jira/browse/KAFKA-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15004649#comment-15004649
]
ASF GitHub Bot commented on KAFKA-2833:
---------------------------------------
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/527
KAFKA-2833: print only group offset / metadata according to the formatter
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka K2833
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/527.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #527
----
commit 6b7a88a84e9f80a29b3ca49ac6db95f5c70e3ee3
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2015-11-13T20:06:55Z
v1
commit f558f027a5db69b351b0b32f52257ae6d3839795
Author: Guozhang Wang <wangg...@gmail.com>
Date: 2015-11-13T20:07:05Z
Merge branch 'trunk' of https://github.com/apache/kafka into K2833
----
> 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)
