consumer: avoid bubbling up retriable broker errors

twmb · Apr 16, 2021 · 111f922 · 111f922
1 parent 3edbe09
commit 111f922
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/consumer.go b/pkg/kgo/consumer.go
@@ -1086,7 +1086,7 @@ func (s *consumerSession) handleListOrEpochResults(loaded loadedOffsets) {
 			use()
 
 		default: // from ErrorCode in a response
-			if !kerr.IsRetriable(load.err) { // non-retriable response error; signal such in a response
+			if !kerr.IsRetriable(load.err) && !isRetriableBrokerErr(load.err) { // non-retriable response error; signal such in a response
 				s.c.addFakeReadyForDraining(load.topic, load.partition, load.err)
 				slowReloads.addLoad(load.topic, load.partition, loaded.loadType, load.request)
 				continue