partition

Documentation

Index

• func CompletePartitionIds(_ *cobra.Command, args []string, _ string) ([]string, cobra.ShellCompDirective)
• type AlterPartitionFlags
• type Operation
  • func (operation *Operation) AlterPartition(topic string, partitionID int32, flags AlterPartitionFlags) error

Functions

func CompletePartitionIds

func CompletePartitionIds(_ *cobra.Command, args []string, _ string) ([]string, cobra.ShellCompDirective)

Types

type AlterPartitionFlags

type AlterPartitionFlags struct {
	Replicas     []int32
	ValidateOnly bool
}

type Operation

type Operation struct {
}

func (*Operation) AlterPartition

func (operation *Operation) AlterPartition(topic string, partitionID int32, flags AlterPartitionFlags) error