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

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.8.0
    • 0.8.2.0
    • controller
    • 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.patch
          4 kB
          Harsha
        2. KAFKA-1096_2014-06-20_15:27:44.patch
          4 kB
          Harsha

        Activity

          People

            sriharsha Harsha
            swapnilghike Swapnil Ghike
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: