Receiver.java

@Slf4j
@Component
public class Receiver {

    @Autowired
    private FulfillmentRepository fulfillmentRepository;

    private CountDownLatch latch = new CountDownLatch(1);

    public CountDownLatch getLatch() {

        return latch;
    }

    @KafkaListener(topics = "${spring.kafka.topic.orders-order}")
    public void receive(FulfillmentRequestEvent fulfillmentRequestEvent) {

        log.info("received payload='{}'", fulfillmentRequestEvent.toString());
        latch.countDown();
        Fulfillment fulfillment = new Fulfillment();
        fulfillment.setId(fulfillmentRequestEvent.getId());
        fulfillment.setTimestamp(fulfillmentRequestEvent.getTimestamp());
        fulfillment.setName(fulfillmentRequestEvent.getName());
        fulfillment.setContact(fulfillmentRequestEvent.getContact());
        fulfillment.setAddress(fulfillmentRequestEvent.getAddress());
        fulfillment.setOrder(fulfillmentRequestEvent.getOrder());
        fulfillmentRepository.save(fulfillment);
    }
}