Method: Ktl::Cluster#decommission_broker

Defined in:
lib/ktl/cluster.rb

#decommission_broker(broker_id) ⇒ Object 



80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/ktl/cluster.rb', line 80

def decommission_broker(broker_id)
  with_zk_client do |zk_client|
    if options.rendezvous?
      plan = RendezvousShufflePlan.new(zk_client, blacklist: [broker_id.to_i])
    else
      plan = DecommissionPlan.new(zk_client, broker_id.to_i)
    end
    reassigner = Reassigner.new(zk_client, limit: options.limit, logger: logger)
    execute_reassignment(reassigner, plan)
  end
end