From 111f92280e582d44cd76107680f15a74e0f921b1 Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Fri, 16 Apr 2021 15:10:34 -0600 Subject: [PATCH] consumer: avoid bubbling up retriable broker errors --- pkg/kgo/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/kgo/consumer.go b/pkg/kgo/consumer.go index 46674601..27a5fae1 100644 --- 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