package log import ( "github.com/segmentio/kafka-go" "go.uber.org/zap" ) var KafkaInfo = kafka.LoggerFunc(zap.S().Infof) var KafkaErr = kafka.LoggerFunc(zap.S().Errorf)