delete

var DeleteTopicCmd = &cobra.Command{
	Use:   "delete",
	Short: "Delete the topics satisfying the passed criteria if any",
	Run: func(command *cobra.Command, args []string) {
		cobraUtil := base.NewCobraUtil(command)
		lastWrite := int64(cobraUtil.GetIntArg("last-write"))
		var baseCmd *base.Cmd
		if lastWrite == 0 {
			baseCmd = base.Init(cobraUtil)
		} else {
			baseCmd = base.Init(cobraUtil, base.WithSSH())
		}
		d := deleteTopic{
			Lister:         baseCmd.GetTopic(),
			Deleter:        baseCmd.GetTopic(),
			lastWrite:      lastWrite,
			dataDir:        cobraUtil.GetStringArg("data-dir"),
			topicWhitelist: cobraUtil.GetStringArg("topic-whitelist"),
			topicBlacklist: cobraUtil.GetStringArg("topic-blacklist"),
			sshPort:        cobraUtil.GetStringArg("ssh-port"),
			sshKeyFilePath: cobraUtil.GetStringArg("ssh-key-file-path"),
			userInput:      &ui.UserInput{},
		}
		d.deleteTopic()
	},
}