1 package de.juplo.kafka.payment.transfer.ports;
3 import de.juplo.kafka.payment.transfer.domain.Transfer;
4 import org.apache.kafka.common.TopicPartition;
6 import java.util.concurrent.CompletableFuture;
9 public interface ReceiveTransferUseCase
11 CompletableFuture<TopicPartition> receive(Transfer transfer);