import de.juplo.kafka.payment.transfer.domain.Transfer;
+import java.util.Map;
import java.util.Optional;
void remove(Long id);
- void resetStorageForPartition(int partition);
+ long activatePartition(int partition);
+
+ void deactivatePartition(int partition, long offset);
+
+ long storedPosition(int partition);
+
+ void storeState(Map<Integer, Long> offsets);
}