The state is periodically stored in a local file, that is read on startup

[demos/kafka/demos-kafka-payment-system-transfer] / src / main / java / de / juplo / kafka / payment / transfer / TransferServiceProperties.java

diff --git a/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceProperties.java b/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceProperties.java
index e001748..907a8b9 100644 (file)
--- a/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceProperties.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceProperties.java
@@ -20,6 +20,8 @@ public class TransferServiceProperties
   private String groupId = "transfers";
   private String groupInstanceId;
   private Map<String, String> instanceIdUriMapping;
+  private String localStateStorePath;
+  private int stateStoreInterval = 60;
 
   public Map<String, String> getInstanceIdUriMapping()
   {