Fix import error in Writer code example in README (#1234)

Fixes #1231
segmentio · Nov 17, 2023 · 6481322 · 6481322
1 parent c6378c3
commit 6481322
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/README.md b/README.md
@@ -401,7 +401,7 @@ for i := 0; i < retries; i++ {
 
     // attempt to create topic prior to publishing the message
     err = w.WriteMessages(ctx, messages...)
-    if errors.Is(err, LeaderNotAvailable) || errors.Is(err, context.DeadlineExceeded) {
+    if errors.Is(err, kafka.LeaderNotAvailable) || errors.Is(err, context.DeadlineExceeded) {
         time.Sleep(time.Millisecond * 250)
         continue
     }