custom resource list

list.rb

def list(directory, zookeeper, topic)
  cmd = %W(
    #{directory}/bin/kafka-topics.sh
    --zookeeper #{zookeeper}
    --describe
    --topic #{topic}
  ).join(" ")

  result = shell_out(cmd).stdout
  extract = ->(a) { a && a.to_i }

  {
    partitions: extract.call(result[/PartitionCount:\s*(\d+)/, 1]),
    replicas: extract.call(result[/ReplicationFactor:\s*(\d+)/, 1])
  }
end