1 package de.juplo.kafka.payment.transfer.ports;
3 import de.juplo.kafka.payment.transfer.domain.Transfer;
5 import java.util.Optional;
8 public interface TransferRepository
10 void store(Transfer transfer);
12 Optional<Transfer> get(Long id);
16 void resetStorageForPartition(int partition);