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