Metric kafka_brokers does not decrease

[hcbraun]

When a broker is shutdown the reported number does not go down:

# HELP kafka_brokers Number of Brokers in the Kafka Cluster.
# TYPE kafka_brokers gauge
kafka_brokers 3

[congwensheng]

hi，Brother, has this problem been solved？I encountered this problem too, please help me

[readygodom]

Have resolved this problem by modifying its reference code.
Just need modify reference file 'github.com/Shopify/sarama/client.go'.
Add this function to refresh broker list.
func (client *client) refreshBrokers() {
for _, broker := range client.brokers {
err := broker.Open(client.conf)
if err != nil {
Logger.Println(err)
}
rs, _ := broker.Connected()
if !rs {
fmt.Println(broker.Addr(),":",broker.ID()," detached.")
client.deregisterBroker(broker)
}
}
}

[mcinquin]

Hi,

Can you provide a PR for this useful fix?

Regards.