Sha256: 14259ef3850bce0997240d42464f023e5cbc6cb5227ea1a3073d51049c3c4225
Contents?: true
Size: 776 Bytes
Versions: 19
Compression:
Stored size: 776 Bytes
Contents
# frozen_string_literal: true
module Karafka
class Cli
class Topics < Cli::Base
# Deletes routing based topics
class Delete < Base
# @return [Boolean] true if any topic was deleted, otherwise false
def call
any_deleted = false
declaratives_routing_topics.each do |topic|
name = topic.name
if existing_topics_names.include?(name)
puts "Deleting topic #{name}..."
Admin.delete_topic(name)
puts "#{green('Deleted')} topic #{name}."
any_deleted = true
else
puts "#{yellow('Skipping')} because topic #{name} does not exist."
end
end
any_deleted
end
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems