X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fports%2FTransferRepository.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fports%2FTransferRepository.java;h=f21604d08219c94512ed68e0e5c1f666fbbcdceb;hp=0629eab18b73c8600624f5c17c1d4717c422dbd0;hb=2432aeedb30ac4c1405045514d8eacb791a4d352;hpb=c64f93de3e59af674885fdad08c521d82f4802d1

diff --git a/src/main/java/de/juplo/kafka/payment/transfer/ports/TransferRepository.java b/src/main/java/de/juplo/kafka/payment/transfer/ports/TransferRepository.java
index 0629eab..f21604d 100644
--- a/src/main/java/de/juplo/kafka/payment/transfer/ports/TransferRepository.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/ports/TransferRepository.java
@@ -2,6 +2,7 @@ package de.juplo.kafka.payment.transfer.ports;
 
 import de.juplo.kafka.payment.transfer.domain.Transfer;
 
+import java.util.Map;
 import java.util.Optional;
 
 
@@ -13,5 +14,11 @@ public interface TransferRepository
 
   void remove(Long id);
 
-  void resetStorageForPartition(int partition);
+  long activatePartition(int partition);
+
+  void deactivatePartition(int partition, long offset);
+
+  long storedPosition(int partition);
+
+  void storeState(Map<Integer, Long> offsets);
 }