class Kafkat::Command::Topics

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/topics.rb, line 9
def run
  topic_names = zookeeper.get_topic_names

  topic_names.each { |name| print_topic_name(name) }
end