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