Switched from single-node (assign) to multi-instance (subscribe)

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

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 2423ab3..0629eab 100644 (file)
--- a/src/main/java/de/juplo/kafka/payment/transfer/ports/TransferRepository.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/ports/TransferRepository.java
@@ -11,7 +11,7 @@ public interface TransferRepository
 
   Optional<Transfer> get(Long id);
 
-  void update(Long id, Transfer.State oldState, Transfer.State newState) throws IllegalArgumentException;
-
   void remove(Long id);
+
+  void resetStorageForPartition(int partition);
 }