feat: make unknown topic or partition error fatal (#87)

* feat: make unknown topic or partition error fatal
Trendyol · Apr 17, 2024 · 0149b0d · 0149b0d
1 parent 3ddae8b
commit 0149b0d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kafka/producer/producer_batch.go b/kafka/producer/producer_batch.go
@@ -151,7 +151,9 @@ func (b *Batch) FlushMessages() {
 
 func isFatalError(err error) bool {
 	e, ok := err.(kafka.Error)
-
+	if ok && errors.Is(err, kafka.UnknownTopicOrPartition) {
+		return true
+	}
 	if (ok && e.Temporary()) ||
 		errors.Is(err, io.ErrUnexpectedEOF) ||
 		errors.Is(err, syscall.ECONNREFUSED) ||