Sha256: 72bf37e10925d08ff0a2bb243e2bf133def5b8f77c2ea175e3c4997274c6cd6a
Contents?: true
Size: 471 Bytes
Versions: 6
Compression:
Stored size: 471 Bytes
Contents
#!/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!)
Version data entries
6 entries across 6 versions & 1 rubygems