Add producer auto resolution case

pinterest · Jan 29, 2025 · 739a32a · 739a32a
1 parent dbe7ae2
commit 739a32a
Showing 1 changed file with 4 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
@@ -277,6 +277,10 @@ ImmutableMap.<Class<? extends Exception>, Map<String, PscErrorHandler.ProducerAc
                                         "not present in metadata after",
                                         new PscErrorHandler.ProducerAction(PscErrorHandler.ActionType.RESET_THEN_THROW, ProducerException.class)
                                 );
+                                put(
+                                        "has passed since batch creation",
+                                        new PscErrorHandler.ProducerAction(PscErrorHandler.ActionType.RESET_THEN_THROW, ProducerException.class)
+                                );
                             }}
                     )