Class: Kazoo::CLI::Topics

Inherits:
Thor
  • Object
show all
Includes:
Common
Defined in:
lib/kazoo/cli/topics.rb

Instance Method Summary collapse

Methods included from Common

included

Instance Method Details

#create(name) ⇒ Object 



18
19
20
21
22
 
# File 'lib/kazoo/cli/topics.rb', line 18

def create(name)
  validate_class_options!

  kafka_cluster.create_topic(name, partitions: options[:partitions], replication_factor: options[:replication_factor])
end

#delete(name) ⇒ Object 



25
26
27
28
29
 
# File 'lib/kazoo/cli/topics.rb', line 25

def delete(name)
  validate_class_options!

  kafka_cluster.topics.fetch(name).destroy
end

#list ⇒ Object 



7
8
9
10
11
12
13
 
# File 'lib/kazoo/cli/topics.rb', line 7

def list
  validate_class_options!

  kafka_cluster.topics.values.sort_by(&:name).each do |topic|
    $stdout.puts topic.name
  end
end

#partitions(topic) ⇒ Object 



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

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