Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1459

kafka.tools.ConsumerOffsetChecker throws NoNodeException

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.1.1
    • Fix Version/s: 0.8.2.0
    • Component/s: tools
    • Labels:

      Description

      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.

        Attachments

        1. KAFKA-1459_2014-05-27_20:19:55.patch
          0.7 kB
          Sriharsha Chintalapani
        2. KAFKA-1459.patch
          3 kB
          Sriharsha Chintalapani

          Activity

            People

            • Assignee:
              sriharsha Sriharsha Chintalapani
              Reporter:
              t1ckt0ck Scott Clasen
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: