groupcmdutil

package
v0.38.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

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

valid values for consumer group reset offset operaion

Variables

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"

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL