lib

var Kafka = cli.Command{
	Name:  "kafka",
	Usage: "kafka related commands",
	Subcommands: cli.Commands{
		{
			Name:  "list-topics",
			Usage: "list kafka topics",
			Flags: []cli.Flag{
				flagEmail,
				flagPassword,
				flagOTP,
				flagProject,
				flagService,
			},
			Action: Do(listTopics),
		},
		{
			Name:  "create-topic",
			Usage: "create kafka topic",
			Flags: []cli.Flag{
				flagEmail,
				flagPassword,
				flagOTP,
				flagProject,
				flagService,
				flagName,
				flagCleanupPolicy,
				flagPartitions,
				flagReplication,
				flagRetentionHours,
			},
			Action: Do(createTopic),
		},
		{
			Name:  "delete-topic",
			Usage: "delete kafka topic",
			Flags: []cli.Flag{
				flagEmail,
				flagPassword,
				flagOTP,
				flagProject,
				flagService,
				flagName,
			},
			Action: Do(deleteTopic),
		},
	},
}