fix imports #8

Kasean · Dec 29, 2023 · db3648a · db3648a
1 parent 46e1ae6
commit db3648a
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/core-back-end/src/main/java/org/student/messaging/archiver/ArchiverListener.java b/core-back-end/src/main/java/org/student/messaging/archiver/ArchiverListener.java
@@ -3,7 +3,7 @@
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.annotation.TopicPartition;
 import org.springframework.stereotype.Service;
-import org.student.messaging.KafkaTopics;
+import org.student.messaging.topics.KafkaTopics;
 
 @Service
 public class ArchiverListener {

diff --git a/core-back-end/src/main/java/org/student/messaging/archiver/ArchiverProducer.java b/core-back-end/src/main/java/org/student/messaging/archiver/ArchiverProducer.java
@@ -3,7 +3,7 @@
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Service;
-import org.student.messaging.KafkaTopics;
+import org.student.messaging.topics.KafkaTopics;
 
 @Service
 public class ArchiverProducer {

diff --git a/...end/src/main/java/org/student/messaging/artifact_processor/ArtifactProcessorListener.java b/...end/src/main/java/org/student/messaging/artifact_processor/ArtifactProcessorListener.java
@@ -3,7 +3,7 @@
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.annotation.TopicPartition;
 import org.springframework.stereotype.Service;
-import org.student.messaging.KafkaTopics;
+import org.student.messaging.topics.KafkaTopics;
 
 @Service
 public class ArtifactProcessorListener {

diff --git a/...end/src/main/java/org/student/messaging/artifact_processor/ArtifactProcessorProducer.java b/...end/src/main/java/org/student/messaging/artifact_processor/ArtifactProcessorProducer.java
@@ -2,7 +2,7 @@
 
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.springframework.kafka.core.KafkaTemplate;
-import org.student.messaging.KafkaTopics;
+import org.student.messaging.topics.KafkaTopics;
 
 public class ArtifactProcessorProducer {
     private final KafkaTemplate<String, byte[]> template;