Documentation
¶
Overview ¶
Package consumeroffset handles collection of consumer offsets for consumer groups
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Collect ¶
func Collect(client connection.Client, kafkaIntegration *integration.Integration) error
Collect collects offset data per consumer group specified in the arguments
Types ¶
type TopicPartitions ¶
TopicPartitions is the substructure within the consumer group structure
Source Files
Click to show internal directories.
Click to hide internal directories.