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

An old controller coming out of long GC could update its epoch to the latest controller's epoch

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.2.0
    • Component/s: controller
    • Labels:
      None

      Description

      If a controller GCs for too long, we could have two controllers in the cluster. The controller epoch is supposed to minimize the damage in such a situation, as the brokers will reject the requests sent by the controller with an older epoch.

      When the old controller is still in long GC, a new controller could be elected. This will fire ControllerEpochListener on the old controller. When it comes out of GC, its ControllerEpochListener will update its own epoch to the new controller's epoch. So both controllers are now able to send out requests with the same controller epoch until the old controller's handleNewSession() can execute in the controller lock.

      ControllerEpochListener does not seem necessary, so we can probably delete it.

        Attachments

        1. KAFKA-1096_2014-06-20_15:27:44.patch
          4 kB
          Sriharsha Chintalapani
        2. KAFKA-1096.patch
          4 kB
          Sriharsha Chintalapani

          Activity

            People

            • Assignee:
              sriharsha Sriharsha Chintalapani
              Reporter:
              swapnilghike Swapnil Ghike
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: