diff --git a/logs/processor/processor.go b/logs/processor/processor.go index ec29851a..e1dc0356 100644 --- a/logs/processor/processor.go +++ b/logs/processor/processor.go @@ -9,9 +9,12 @@ package processor import ( "context" + "fmt" "log" + "os" "sync" + coreconfig "flashcat.cloud/categraf/config" logsconfig "flashcat.cloud/categraf/config/logs" "flashcat.cloud/categraf/logs/diagnostic" "flashcat.cloud/categraf/logs/message" @@ -94,6 +97,9 @@ func (p *Processor) processMessage(msg *message.Message) { log.Println("unable to encode msg ", err) return } + if coreconfig.Config.DebugMode { + fmt.Fprintf(os.Stdout, "D! log item: %s", string(content)) + } msg.Content = content p.outputChan <- msg }