Method: Kafkat::Command::Topics#run

Defined in:
lib/kafkat/command/topics.rb

#runObject



9
10
11
12
# File 'lib/kafkat/command/topics.rb', line 9

def run
  ts = zookeeper.get_topics
  ts.each { |name, t| print_topic(t) }
end