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 {