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

…21484) (#21508) (cherry picked from commit 3d8e7dd)
elastic · Oct 5, 2020 · 5d60433 · 5d60433
1 parent c570e44
commit 5d60433
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