Do not fail on customer not found

Apicurio · Jan 22, 2024 · 0119aeb · 0119aeb
1 parent b315fbb
commit 0119aeb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/io/apicurio/registry/probe/kafka/CustomersConsumer.java b/src/main/java/io/apicurio/registry/probe/kafka/CustomersConsumer.java
@@ -4,6 +4,7 @@
 import io.apicurio.registry.probe.smoke.ProbeMonitoring;
 import io.smallrye.reactive.messaging.annotations.Blocking;
 import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.persistence.EntityNotFoundException;
 import jakarta.transaction.Transactional;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Message;
@@ -38,6 +39,9 @@ public CompletionStage<Void> consume(Message<Envelope> customerMessage) {
                 //Tombstone message, just ack
                 customerMessage.ack();
             }
+        } catch (EntityNotFoundException enfe) {
+            log.warn("Customer in message not found: {}", enfe.getCause(), enfe);
+            return customerMessage.ack();
         } catch (Exception e) {
             log.error("Exception detected in the Probe application: {}", e.getCause(), e);
             return customerMessage.nack(e);