X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=transfer%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2FTransferService.java;h=a99634e9317f8b0c3f4e56ad6ee8a880794be7ae;hb=251ca7f6a62e5fd2a8086925ba87d9f712cc2d98;hp=9da09a91d3967db54c49f06ee9d38638a13e33dc;hpb=9b858aa3617b75af180e47bfa6ff1f441c6252e9;p=demos%2Fkafka%2Fdemos-kafka-payment-system-setup

diff --git a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
index 9da09a9..a99634e 100644
--- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
+++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
@@ -1,11 +1,11 @@
 package de.juplo.kafka.payment.transfer;
 
 
-import de.trion.microservices.avro.Order;
-import de.trion.microservices.avro.OrderState;
 import java.net.URI;
 import java.util.UUID;
-import javax.validation.Valid;
+
+import de.juplo.kafka.payment.avro.Order;
+import de.juplo.kafka.payment.avro.OrderState;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.slf4j.Logger;
@@ -23,7 +23,7 @@ public class TransferService
 {
   private final static Logger LOG = LoggerFactory.getLogger(TransferService.class);
 
-  private final KafkaProducer<UUID,Order> producer;
+  private final KafkaProducer<UUID, Order> producer;
   private final String topic;
   private final String path;