Review Board 1.7.22


Patch for KAFKA-1134

Review Request #15953 - Created Dec. 3, 2013 and updated

Guozhang Wang
KAFKA-1134
Reviewers
kafka
kafka
KAFKA-1134.v1

 
core/src/main/scala/kafka/controller/ControllerChannelManager.scala
Revision beca460dfe0f4df5ccd7f6358e44cbe742d256e5 New Change
[20] 87 lines
[+20]
88
  }
88
  }
89

    
   
89

   
90
  private def removeExistingBroker(brokerId: Int) {
90
  private def removeExistingBroker(brokerId: Int) {
91
    try {
91
    try {
92
      brokerStateInfo(brokerId).channel.disconnect()
92
      brokerStateInfo(brokerId).channel.disconnect()

    
   
93
      brokerStateInfo(brokerId).messageQueue.clear()
93
      brokerStateInfo(brokerId).requestSendThread.shutdown()
94
      brokerStateInfo(brokerId).requestSendThread.shutdown()
94
      brokerStateInfo.remove(brokerId)
95
      brokerStateInfo.remove(brokerId)
95
    }catch {
96
    }catch {
96
      case e: Throwable => error("Error while removing broker by the controller", e)
97
      case e: Throwable => error("Error while removing broker by the controller", e)
97
    }
98
    }
[+20] [20] 183 lines
core/src/main/scala/kafka/controller/KafkaController.scala
Revision 3beaf75f8285c8b6146aced2fefda4234cf1d307 New Change
 
core/src/main/scala/kafka/controller/PartitionStateMachine.scala
Revision 829163afab99706f7a34408eda2504c8262e572e New Change
 
  1. core/src/main/scala/kafka/controller/ControllerChannelManager.scala: Loading...
  2. core/src/main/scala/kafka/controller/KafkaController.scala: Loading...
  3. core/src/main/scala/kafka/controller/PartitionStateMachine.scala: Loading...