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=0629eab18b73c8600624f5c17c1d4717c422dbd0;hp=e44a1d66a0d4051b09722f17c5b9380ee2a1e55f;hb=43ea59755f9673864a3ef95250009f091e99a760;hpb=cbfe4b796266ff7b9689fb69c5a8efee8ebb130a

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 e44a1d6..0629eab 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
@@ -12,4 +12,6 @@ public interface TransferRepository
   Optional<Transfer> get(Long id);
 
   void remove(Long id);
+
+  void resetStorageForPartition(int partition);
 }