topic first step

topic.rb

property :topic,      String, name_property: true
property :partitions, Fixnum, default: 3
property :replicas,   Fixnum, default: 3
property :zookeeper,  String, default: "localhost:2181"
property :directory,  String, default: "/kafka"

action :create do
  cmd = %W(
    #{directory}/bin/kafka-topics.sh
    --zookeeper #{zookeeper}
    --create
    --topic #{topic}
    --replication-factor #{replicas}
    --partitions #{partitions}
  ).join(" ")
  
  result = shell_out(cmd)
end