Old entries are removed from the outbox-table in batches

[demos/kafka/outbox] / delivery / src / main / java / de / juplo / kafka / outbox / delivery / OutboxRepository.java

diff --git a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxRepository.java b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxRepository.java
index abf2d1d..d6c814d 100644 (file)
--- a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxRepository.java
+++ b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxRepository.java
@@ -19,7 +19,7 @@ public class OutboxRepository
   private static final String SQL_UPDATE =
       "INSERT INTO outbox (key, value, issued) VALUES (:key, :value, :issued)";
   private static final String SQL_DELETE =
-      "DELETE FROM outbox WHERE id = :id";
+      "DELETE FROM outbox WHERE id <= :id";
 
   private final NamedParameterJdbcTemplate jdbcTemplate;