consumergroup

Documentation

Index

• Constants
• Variables
• func GetActiveConsumersCount(consumers []kafkainstanceclient.Consumer) (count int)
• func GetPartitionsWithLag(consumers []kafkainstanceclient.Consumer) (partitionsWithLag int)
• func GetUnassignedPartitions(consumers []kafkainstanceclient.Consumer) (unassignedPartitions int)
• type Validator
  • func (v *Validator) ValidateOffset(offset string) error
  • func (v *Validator) ValidateOffsetValue(offset string, value string) error

Constants

const (
	OffsetAbsolute  = "absolute"
	OffsetEarliest  = "earliest"
	OffsetTimestamp = "timestamp"
	OffsetLatest    = "latest"
)

valid values for consumer group reset offset operaion

Variables

var ValidOffsets = []string{OffsetAbsolute, OffsetEarliest, OffsetTimestamp, OffsetLatest}

Functions

func GetActiveConsumersCount

func GetActiveConsumersCount(consumers []kafkainstanceclient.Consumer) (count int)

func GetPartitionsWithLag

func GetPartitionsWithLag(consumers []kafkainstanceclient.Consumer) (partitionsWithLag int)

GetPartitionsWithLag returns the number of partitions having lag for a consumer group

func GetUnassignedPartitions

func GetUnassignedPartitions(consumers []kafkainstanceclient.Consumer) (unassignedPartitions int)

Types

type Validator

type Validator struct {
	Localizer localize.Localizer
}

func (*Validator) ValidateOffset

func (v *Validator) ValidateOffset(offset string) error

ValidateOffset checks if value v is a valid value for --offset

func (*Validator) ValidateOffsetValue

func (v *Validator) ValidateOffsetValue(offset string, value string) error

ValidateOffsetValue validates value for timestamp and absolute offset value for absolute offset should be integer and timestamp should be in format "yyyy-MM-dd'T'HH:mm:ssz"