Old entries are removed from the outbox-table in batches

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

diff --git a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/ApplicationProperties.java b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/ApplicationProperties.java
index 4e36aa4..74f91d4 100644 (file)
--- a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/ApplicationProperties.java
+++ b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/ApplicationProperties.java
@@ -4,6 +4,8 @@ import lombok.Getter;
 import lombok.Setter;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import java.time.Duration;
+
 
 @ConfigurationProperties("de.juplo.kafka.outbox")
 @Getter
@@ -12,4 +14,5 @@ public class ApplicationProperties
 {
   String bootstrapServers = "localhost:9092";
   String topic = "outbox";
+  Duration cleanupInterval = Duration.ofSeconds(10);
 }