src/main/java/ru/no_copy/monitoring/MonitoringApplication.java

@@ -2,7 +2,6 @@ package ru.no_copy.monitoring;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 public class MonitoringApplication {

src/main/java/ru/no_copy/monitoring/service/MonitoringService.java

@@ -22,7 +22,7 @@ public class MonitoringService {
 
     private final ObjectMapper objectMapper;
 
-    private final KafkaTemplate<String, SearchResponse.ImageResult> kafkaTemplate;
+    private final KafkaTemplate<String, Object> kafkaTemplate;
 
     public void execute(String message) throws IOException, TimeoutException {
         MonitoringDTO monitoring;
@@ -45,7 +45,7 @@ public class MonitoringService {
         log.info("Images count: {}", images.size());
 
         for (SearchResponse.ImageResult imageResult: images) {
-            kafkaTemplate.send("monitoring-results", imageResult);
+            kafkaTemplate.send("monitoring-results", objectMapper.writeValueAsString(imageResult));
         }
     }
 }

src/test/java/ru/no_copy/monitoring/MonitoringApplicationTests.java

@@ -1,13 +0,0 @@
-package ru.no_copy.monitoring;
-
-import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
-
-@SpringBootTest
-class MonitoringApplicationTests {
-
-	@Test
-	void contextLoads() {
-	}
-
-}