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