in kafka/common.go [378:388]
func topicFieldFunc(f TopicLogFieldFunc) TopicLogFieldFunc {
return func(t string) zap.Field {
if f == nil {
return zap.Skip()
}
if field := f(t); field.Type > zapcore.UnknownType {
return field
}
return zap.Skip()
}
}