Explorar el Código

Nicer fetch metadata logging

Willem van Bergen hace 11 años
padre
commit
802cae39ff
Se han modificado 1 ficheros con 5 adiciones y 1 borrados
  1. 5 1
      client.go

+ 5 - 1
client.go

@@ -504,7 +504,11 @@ func (client *Client) refreshMetadata(topics []string, retriesRemaining int) err
 	}
 
 	for broker := client.any(); broker != nil; broker = client.any() {
-		Logger.Printf("Fetching metadata for %v from broker %s\n", topics, broker.addr)
+		if len(topics) > 0 {
+			Logger.Printf("Fetching metadata for %v from broker %s\n", topics, broker.addr)
+		} else {
+			Logger.Printf("Fetching metadata for all topics from broker %s\n", broker.addr)
+		}
 		response, err := broker.GetMetadata(client.id, &MetadataRequest{Topics: topics})
 
 		switch err {