Versions in this module Expand all Collapse all v1 v1.7.1 Dec 1, 2021 Changes in this version + const ConsumerError + const FailedToProduceMsg + const ProducerError + var ConsumerErrCnt uint64 + var ErrorLogger *log.Logger + var InfoLogger *log.Logger + var ProduceMsgCnt uint64 + var ProducerErrCnt uint64 + var WarningLogger *log.Logger + func ConvertUint64ToByteArray(num uint64) []byte + func DatadogGauge(metricsName string, val float64, tags []string) + func DatadogIncrement(metricsName string, incrval float64, tags []string) + func GetRusage(metricsName string) error + func GetRusageMetrics(metricsName string, wg *sync.WaitGroup, doneChan chan bool, ...) + func HandleMessage(e *kafka.Message, hwmarks map[string]uint64) bool + func HandleStatsEvent(e *kafka.Stats, topic string) error + func InitLogFiles(filename string) + func PrintConsumerStatus(consumer string) + func PrintProducerStatus(producer string) + func ProducerDeliveryCheck(e *kafka.Message)
Go to main page