From ea2ac477be53d39c601c24492794d882e6f59410 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Sun, 6 Oct 2024 13:53:30 +0300 Subject: [PATCH] set UnknownTopicRetries with 0 Signed-off-by: Vasiliy Tolstov --- kgo.go | 1 + 1 file changed, 1 insertion(+) diff --git a/kgo.go b/kgo.go index 424a970..08fbcb5 100644 --- a/kgo.go +++ b/kgo.go @@ -443,6 +443,7 @@ func NewBroker(opts ...broker.Option) *Broker { kgo.BlockRebalanceOnPoll(), kgo.Balancers(kgo.CooperativeStickyBalancer()), kgo.FetchIsolationLevel(kgo.ReadUncommitted()), + kgo.UnknownTopicRetries(0), } if options.Context != nil {