From 9b5619fc94b3f6907f5093cad31189dac36266f5 Mon Sep 17 00:00:00 2001 From: Anthony Saieva Date: Tue, 16 Apr 2024 13:55:18 +0000 Subject: [PATCH] fix: removing unused main and adding error logging to otelexporter Signed-off-by: Anthony Saieva --- core/processor/otelexporter.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/processor/otelexporter.go b/core/processor/otelexporter.go index f7f14af0..9bc3381d 100644 --- a/core/processor/otelexporter.go +++ b/core/processor/otelexporter.go @@ -115,6 +115,10 @@ func (s *OTELExporter) Process(ch []interface{}, wg *sync.WaitGroup) { nil, ) + if err != nil { + logger.Trace.Printf("OtelExporter Error producing kafka message %v", err) + } + } } } @@ -122,5 +126,3 @@ func (s *OTELExporter) Process(ch []interface{}, wg *sync.WaitGroup) { func (s *OTELExporter) SetOutChan(ch []interface{}) {} func (s *OTELExporter) Cleanup() {} - -func main() {}