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

ConsumerOffsetChecker does not work with 0.8

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: None
    • Component/s: core
    • Labels:
      None

      Description

      The ConsumerOffsetChecker does not work anymore with 0.8, this tool is very useful when used with the MirrorMaker.

      Here is a patch to make it work with some cosmetic changes:

      • script-friendly formatting (one line per partition)
      • offsets do not correspond to bytes anymore (so the lag is in number of messages, not GiB)
      • --broker-info optional option to print the broker list at the end (like the previous version)

      Example:

      bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect zoo.example.org:2181
      Group Topic Pid Offset logSize Lag Owner
      KafkaMirror test 0 215385 215385 0 Some(KafkaMirror_broker01-1379350-71cf9117-0)
      KafkaMirror test 1 683564 683564 0 Some(KafkaMirror_broker03-1379351-71cf9117-0)
      KafkaMirror test2 0 176943 176943 0 Some(KafkaMirror_broker05-1379353-71cf91

        Attachments

        1. KAFKA-685.patch
          6 kB
          Maxime Brugidou
        2. KAFKA-685-2.patch
          5 kB
          Maxime Brugidou

          Activity

            People

            • Assignee:
              brugidou Maxime Brugidou
              Reporter:
              brugidou Maxime Brugidou
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: