We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c6378c3 commit 6481322Copy full SHA for 6481322
README.md
@@ -401,7 +401,7 @@ for i := 0; i < retries; i++ {
401
402
// attempt to create topic prior to publishing the message
403
err = w.WriteMessages(ctx, messages...)
404
- if errors.Is(err, LeaderNotAvailable) || errors.Is(err, context.DeadlineExceeded) {
+ if errors.Is(err, kafka.LeaderNotAvailable) || errors.Is(err, context.DeadlineExceeded) {
405
time.Sleep(time.Millisecond * 250)
406
continue
407
}
0 commit comments