Make the internal RefreshFrequency of sarama to match the flag value

kafka_exporter.go

@@ -170,19 +170,21 @@ func NewExporter(opts kafkaOpts, topicFilter string, groupFilter string) (*Expor
 		zookeeperClient, err = kazoo.NewKazoo(opts.uriZookeeper, nil)
 	}
 
-	client, err := sarama.NewClient(opts.uri, config)
-
+	interval, err := time.ParseDuration(opts.metadataRefreshInterval)
 	if err != nil {
-		plog.Errorln("Error Init Kafka Client")
+		plog.Errorln("Cannot parse refresh metadata interval")
 		panic(err)
 	}
-	plog.Infoln("Done Init Clients")
 
-	interval, err := time.ParseDuration(opts.metadataRefreshInterval)
+	config.Metadata.RefreshFrequency = interval
+
+	client, err := sarama.NewClient(opts.uri, config)
+
 	if err != nil {
-		plog.Errorln("Cannot parse refresh metadata interval")
+		plog.Errorln("Error Init Kafka Client")
 		panic(err)
 	}
+	plog.Infoln("Done Init Clients")
 
 	// Init our exporter.
 	return &Exporter{
@@ -226,6 +228,7 @@ func (e *Exporter) Collect(ch chan<- prometheus.Metric) {
 	offset := make(map[string]map[int32]int64)
 
 	now := time.Now()
+
 	if now.After(e.nextMetadataRefresh) {
 		plog.Info("Refreshing client metadata")