projects
/
demos
/
kafka
/
outbox
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fixed bug on first start-up (no current offsets)
[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 lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import java.time.Duration;
+
@ConfigurationProperties("de.juplo.kafka.outbox")
@Getter
@ConfigurationProperties("de.juplo.kafka.outbox")
@Getter
@@
-12,4
+14,5
@@
public class ApplicationProperties
{
String bootstrapServers = "localhost:9092";
String topic = "outbox";
{
String bootstrapServers = "localhost:9092";
String topic = "outbox";
+ Duration cleanupInterval = Duration.ofSeconds(10);
}
}