You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2014/05/27 22:45:03 UTC

[jira] [Closed] (KAFKA-1459) kafka.tools.ConsumerOffsetChecker throws NoNodeException

     [ https://issues.apache.org/jira/browse/KAFKA-1459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Neha Narkhede closed KAFKA-1459.
--------------------------------


> kafka.tools.ConsumerOffsetChecker throws NoNodeException
> --------------------------------------------------------
>
>                 Key: KAFKA-1459
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1459
>             Project: Kafka
>          Issue Type: Bug
>          Components: tools
>    Affects Versions: 0.8.1.1
>            Reporter: Scott Clasen
>            Assignee: Sriharsha Chintalapani
>              Labels: newbie
>         Attachments: KAFKA-1459.patch
>
>
> When using the kafka.tools.ConsumerOffsetChecker to check offsets for consumers that are doing manual offset management, and offsets for some but not all partitions have been stored, the offset checker will throw a no node exception.  It should probably return 0 for partitions that dont have an offset recorded yet.
> In this case I was using github.com/pinterest/secor, which may read thousands or millions of messages from a partition before committing an offset.



--
This message was sent by Atlassian JIRA
(v6.2#6252)