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

jsoriano · web-flow · commit 3d8e7dd6fe11 · 2020-10-05T10:51:51.000+02:00
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
 

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ func (b *Broker) Connect() error {`
`119`	`119`	`c, err := getClusterWideClient(b.Addr(), b.cfg)`
`120`	`120`	`if err != nil {`
`121`	`121`	`closeBroker(b.broker)`
`122`		`- return fmt.Errorf("Could not get cluster client for advertised broker with address %v", b.Addr())`
	`122`	`+ return fmt.Errorf("getting cluster client for advertised broker with address %v: %w", b.Addr(), err)`
`123`	`123`	`}`
`124`	`124`	`b.client = c`
`125`	`125`