Remove metadata prefix from config as not needed (elastic#3095) (elas…

…tic#3099)

(cherry picked from commit e2a4bbe)

metricbeat/_meta/beat.full.yml

@@ -95,9 +95,8 @@ metricbeat.modules:
   #hosts: ["localhost:9092"]
 
   #client_id: metricbeat
-
-  #metadata.retries: 3
-  #metadata.backoff: 250ms
+  #retries: 3
+  #backoff: 250ms
 
   # List of Topics to query metadata for. If empty, all topics will be queried.
   #topics: []

metricbeat/docs/modules/kafka.asciidoc

@@ -25,9 +25,8 @@ metricbeat.modules:
   #hosts: ["localhost:9092"]
 
   #client_id: metricbeat
-
-  #metadata.retries: 3
-  #metadata.backoff: 250ms
+  #retries: 3
+  #backoff: 250ms
 
   # List of Topics to query metadata for. If empty, all topics will be queried.
   #topics: []

metricbeat/metricbeat.full.yml

@@ -95,9 +95,8 @@ metricbeat.modules:
   #hosts: ["localhost:9092"]
 
   #client_id: metricbeat
-
-  #metadata.retries: 3
-  #metadata.backoff: 250ms
+  #retries: 3
+  #backoff: 250ms
 
   # List of Topics to query metadata for. If empty, all topics will be queried.
   #topics: []

metricbeat/module/kafka/_meta/config.yml

@@ -5,9 +5,8 @@
   #hosts: ["localhost:9092"]
 
   #client_id: metricbeat
-
-  #metadata.retries: 3
-  #metadata.backoff: 250ms
+  #retries: 3
+  #backoff: 250ms
 
   # List of Topics to query metadata for. If empty, all topics will be queried.
   #topics: []

metricbeat/module/kafka/partition/config.go

@@ -8,7 +8,8 @@ import (
 )
 
 type connConfig struct {
-	Metadata metaConfig         `config:"metadata"`
+	Retries  int                `config:"retries" validate:"min=0"`
+	Backoff  time.Duration      `config:"backoff" validate:"min=0"`
 	TLS      *outputs.TLSConfig `config:"ssl"`
 	Username string             `config:"username"`
 	Password string             `config:"password"`
@@ -17,15 +18,11 @@ type connConfig struct {
 }
 
 type metaConfig struct {
-	Retries int           `config:"retries" validate:"min=0"`
-	Backoff time.Duration `config:"backoff" validate:"min=0"`
 }
 
 var defaultConfig = connConfig{
-	Metadata: metaConfig{
-		Retries: 3,
-		Backoff: 250 * time.Millisecond,
-	},
+	Retries:  3,
+	Backoff:  250 * time.Millisecond,
 	TLS:      nil,
 	Username: "",
 	Password: "",

metricbeat/module/kafka/partition/partition.go

@@ -52,8 +52,8 @@ func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
 	cfg.Net.DialTimeout = base.Module().Config().Timeout
 	cfg.Net.ReadTimeout = base.Module().Config().Timeout
 	cfg.ClientID = config.ClientID
-	cfg.Metadata.Retry.Max = config.Metadata.Retries
-	cfg.Metadata.Retry.Backoff = config.Metadata.Backoff
+	cfg.Metadata.Retry.Max = config.Retries
+	cfg.Metadata.Retry.Backoff = config.Backoff
 	if tls != nil {
 		cfg.Net.TLS.Enable = true
 		cfg.Net.TLS.Config = tls.BuildModuleConfig("")