1 package de.juplo.kafka.payment.transfer.ports;
3 import de.juplo.kafka.payment.transfer.domain.Transfer;
6 import java.util.Optional;
9 public interface TransferRepository
11 void store(Transfer transfer);
13 Optional<Transfer> get(Long id);
17 long activatePartition(int partition);
19 void deactivatePartition(int partition, long offset);
21 long storedPosition(int partition);
23 void storeState(Map<Integer, Long> offsets);