Include original error when metricbeat fails to connect with Kafka (e…

…lastic#21484)
jsoriano · Oct 8, 2020 · 7d6311d · 7d6311d
1 parent 94f7632
commit 7d6311d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metricbeat/module/kafka/broker.go b/metricbeat/module/kafka/broker.go
@@ -119,7 +119,7 @@ func (b *Broker) Connect() error {
 	c, err := getClusterWideClient(b.Addr(), b.cfg)
 	if err != nil {
 		closeBroker(b.broker)
-		return fmt.Errorf("Could not get cluster client for advertised broker with address %v", b.Addr())
+		return fmt.Errorf("getting cluster client for advertised broker with address %v: %w", b.Addr(), err)
 	}
 	b.client = c