chore: map to trace

influxdata · Sep 16, 2024 · ac25c7b · ac25c7b
1 parent 872d93d
commit ac25c7b
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/plugins/inputs/kinesis_consumer/kinesis_consumer.go b/plugins/inputs/kinesis_consumer/kinesis_consumer.go
@@ -101,11 +101,14 @@ func (t *TelegrafLoggerWrapper) Log(args ...interface{}) {
 
 func (t *TelegrafLoggerWrapper) Logf(classification logging.Classification, format string, v ...interface{}) {
 	switch classification {
+	case logging.Debug:
+		format = "DEBUG " + format
 	case logging.Warn:
-		t.Logger.Warnf(format, v...)
+		format = "WARN" + format
 	default:
-		t.Logger.Tracef(format, v...)
+		format = "INFO " + format
 	}
+	t.Logger.Tracef(format, v...)
 }
 
 func (k *KinesisConsumer) connect(ac telegraf.Accumulator) error {