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

kafka.tools.ConsumerOffsetChecker throws NoNodeException

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.8.1.1
    • 0.8.2.0
    • tools

    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
          Harsha
        2. KAFKA-1459.patch
          3 kB
          Harsha

        Activity

          People

            sriharsha Harsha
            t1ckt0ck Scott Clasen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: