custom resource alter

alter.rb

require "chef/log"

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

  result = shell_out(cmd)
  Chef::Log.error(result.stderr) unless result.stdout =~ /Adding partitions succeeded!/
end