class Kafkat::Partition
Public Instance Methods
has_leader?(brokers)
click to toggle source
# File lib/kafkat/cluster/partition.rb, line 3 def has_leader?(brokers) leader && leader != -1 && brokers.include?(leader) end
under_replicated?()
click to toggle source
# File lib/kafkat/cluster/partition.rb, line 7 def under_replicated? isr.size < replicas.size end