kafka_acls

Documentation

Index

• func NewConvertKafkaAclsCmd() *cobra.Command
• type KafkaAclsGenerator
  • func NewKafkaAclsGenerator(opts MigrateKafkaAclsOpts) *KafkaAclsGenerator
  • func (kg *KafkaAclsGenerator) Run() error
• type MigrateKafkaAclsOpts

Functions

func NewConvertKafkaAclsCmd

func NewConvertKafkaAclsCmd() *cobra.Command

Types

type KafkaAclsGenerator

type KafkaAclsGenerator struct {
	// contains filtered or unexported fields
}

func NewKafkaAclsGenerator

func NewKafkaAclsGenerator(opts MigrateKafkaAclsOpts) *KafkaAclsGenerator

func (*KafkaAclsGenerator) Run

func (kg *KafkaAclsGenerator) Run() error

type MigrateKafkaAclsOpts

type MigrateKafkaAclsOpts struct {
	ClusterName               string
	KafkaAcls                 []types.Acls
	TargetClusterId           string
	TargetClusterRestEndpoint string
	OutputDir                 string
	Force                     bool
	SkipAuditReport           bool
	PreventDestroy            bool
}