Add another producer auto resolution scenario

pinterest · Jan 31, 2025 · 06b8280 · 06b8280
1 parent d3e666e
commit 06b8280
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/psc/src/main/java/com/pinterest/psc/common/kafka/KafkaErrors.java b/psc/src/main/java/com/pinterest/psc/common/kafka/KafkaErrors.java
@@ -17,6 +17,7 @@
 import org.apache.kafka.common.errors.InterruptException;
 import org.apache.kafka.common.errors.InvalidOffsetException;
 import org.apache.kafka.common.errors.NotLeaderForPartitionException;
+import org.apache.kafka.common.errors.NotLeaderOrFollowerException;
 import org.apache.kafka.common.errors.ProducerFencedException;
 import org.apache.kafka.common.errors.SerializationException;
 import org.apache.kafka.common.errors.SslAuthenticationException;
@@ -248,6 +249,14 @@ ImmutableMap.<Class<? extends Exception>, Map<String, PscErrorHandler.ProducerAc
                             }}
                     )
 
+                    // NotLeaderOrFollowerException
+                    .put(
+                            NotLeaderOrFollowerException.class,
+                            new LinkedHashMap<String, PscErrorHandler.ProducerAction>(1) {{
+                                put("", new PscErrorHandler.ProducerAction(PscErrorHandler.ActionType.RESET_THEN_THROW, ProducerException.class));
+                            }}
+                    )
+
                     // ProducerFencedException
                     .put(
                             ProducerFencedException.class,