Kafka
  1. Kafka
  2. KAFKA-255

A tool to UPDATE Zookeeper partition-offset with input from a file

    Details

    • Type: Task Task
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.7.1
    • Component/s: None
    • Labels:
      None

      Description

      A utility that updates the offset of broker partitions in ZK.

      This utility expects 2 input files as arguments:
      1. consumer properties file
      2. a file contains partition offsets data such as:
      (This output data file can be obtained by running kafka.tools.GetZkOffsets)

      test01/3-0:285038193
      test01/1-0:286894308

      1. kafka-255-v1.patch
        4 kB
        John Fung
      2. kafka-255-v2.patch
        5 kB
        John Fung

        Activity

        Hide
        John Fung added a comment -

        Attached kafka-255-v2.patch which has changes suggested in the review in kafka-254.

        Show
        John Fung added a comment - Attached kafka-255-v2.patch which has changes suggested in the review in kafka-254.
        Hide
        Jun Rao added a comment -

        Thanks John. Committed the patch with the following minor changes:
        1. Rename the tool to ImportZkOffsets.
        2. Remove the group option since we can always change the groups to be imported by manipulating the input file.
        3. Remove unused imports.

        Show
        Jun Rao added a comment - Thanks John. Committed the patch with the following minor changes: 1. Rename the tool to ImportZkOffsets. 2. Remove the group option since we can always change the groups to be imported by manipulating the input file. 3. Remove unused imports.

          People

          • Assignee:
            John Fung
            Reporter:
            John Fung
          • Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development