Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 GetUnconsumedPartitions ¶
func GetUnconsumedPartitions(consumers []kafkainstanceclient.Consumer) (unconsumedPartitions int)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.