fix(inputs.amqp_consumer): Print error on connection failure (#13777)

2023-08-28 02:25:32 -06:00 · 2023-08-28 02:25:32 -06:00 · 6f5e5be7b2
parent cc612ca35a
commit 6f5e5be7b2
1 changed files with 1 additions and 1 deletions
--- a/plugins/inputs/amqp_consumer/amqp_consumer.go
+++ b/plugins/inputs/amqp_consumer/amqp_consumer.go
@ -226,7 +226,7 @@ func (a *AMQPConsumer) connect(amqpConf *amqp.Config) (<-chan amqp.Delivery, err
 			a.Log.Debugf("Connected to %q", broker)
 			break
 		}
-		a.Log.Debugf("Error connecting to %q", broker)
+		a.Log.Errorf("Error connecting to %q: %s", broker, err)
 	}

 	if a.conn == nil {