#!/usr/bin/env ruby

require_relative '../config/environment'

class DeleteTopic < Thor
  default_command :delete

  desc 'NAME', 'delete an existing Apache Kafka topic'
  option :verbose, aliases: '-v', type: :boolean,
         desc: 'Enable verbose outputs'
  def delete(name)
    debug! options

    unless topic?(name)
      STDERR.puts "The topic '#{name}' does not exists."
      exit 1
    end

    KafkaClient.delete_topic name
  end
end
DeleteTopic.start(args!)