lib/kafka/client.rb
# Lists all topics in the cluster.
#
# @return [Array<String>] the list of topic names.
Lists all topics in the cluster.
Lists all topics in the cluster .
def topics
      attempts = 0
      begin
        attempts += 1
        @cluster.list_topics
      rescue Kafka::ConnectionError
        @cluster.mark_as_stale!
        retry unless attempts > 1
        raise
      end
    end
def topics attempts = 0 begin attempts += 1 @cluster . list_topics rescue Kafka :: ConnectionError @cluster . mark_as_stale! retry unless attempts > 1 raise end end
Lists all topics in the cluster.
Lists all topics in the cluster .
the list of topic names.
the list of topic names .
Array<String>