Selaa lähdekoodia

Updated "retrying" log message when BackoffFunc implemented

The "client/metadata retrying" log message was always reporting
the sleep duration as `config.Metadata.Retry.Backoff`, regardless
of whether `config.Metadata.Retry.BackoffFunc` is implemented.

We now report the actual retry time before sleeping.
Blake Caldwell 5 vuotta sitten
vanhempi
commit
38f81f8298
1 muutettua tiedostoa jossa 1 lisäystä ja 1 poistoa
  1. 1 1
      client.go

+ 1 - 1
client.go

@@ -798,7 +798,7 @@ func (client *client) tryRefreshMetadata(topics []string, attemptsRemaining int,
 				Logger.Println("client/metadata skipping last retries as we would go past the metadata timeout")
 				return err
 			}
-			Logger.Printf("client/metadata retrying after %dms... (%d attempts remaining)\n", client.conf.Metadata.Retry.Backoff/time.Millisecond, attemptsRemaining)
+			Logger.Printf("client/metadata retrying after %dms... (%d attempts remaining)\n", backoff/time.Millisecond, attemptsRemaining)
 			if backoff > 0 {
 				time.Sleep(backoff)
 			}