client retriable req: fix err bug

When retrying requests, we would not save the err from the broker call properly.
twmb · Aug 29, 2021 · 307c22e · 307c22e
1 parent 198edc7
commit 307c22e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/client.go b/pkg/kgo/client.go
@@ -629,7 +629,7 @@ start:
  // broker is different than the current, we also retry.
  if r.cl.shouldRetry(tries, err) || r.cl.shouldRetry(tries, retryErr) {
  if r.cl.waitTries(ctx, tries) {
- next, err = r.br()
+ next, nextErr = r.br()
  goto start
  }
  } else if r.cl.shouldRetryNext(tries, err) {