Method: Kazoo::CLI::Topics#partitions

Defined in:
lib/kazoo/cli/topics.rb

#partitions(topic) ⇒ Object 



32
33
34
35
36
37
38
39
 
# File 'lib/kazoo/cli/topics.rb', line 32

def partitions(topic)
  validate_class_options!

  topic = kafka_cluster.topics.fetch(topic)
  topic.partitions.each do |partition|
    puts "#{partition.key}\tReplicas: #{partition.replicas.map(&:id).join(",")}\tISR: #{partition.isr.map(&:id).join(",")}"
  end
end