카프카 주석 해제

kdt-8-4 · Dec 4, 2023 · ea4ca7e · ea4ca7e
1 parent 0c40d50
commit ea4ca7e
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/main/java/com/weatherfit/board/service/BoardService.java b/src/main/java/com/weatherfit/board/service/BoardService.java
@@ -151,8 +151,8 @@ public BoardEntity insertBoard(BoardEntity board) {
         String joiendString = board.getTemperature() + "/" + String.join("/", board.getCategory());
         String joiendString2 = String.join("/", board.getHashTag());
 
-//        kafkaTemplate.send("category", 0, "category", joiendString);
-//        kafkaTemplate.send("hashtag", 0, "hashtag", joiendString2);
+        kafkaTemplate.send("category", 0, "category", joiendString);
+        kafkaTemplate.send("hashtag", 0, "hashtag", joiendString2);
         return board;
     }
 
@@ -218,8 +218,8 @@ public void patchBoard(int boardId, String boardJson, MultipartFile[] images, St
         boardRepository.save(originalBoard);
 
         // 카프카 전송
-//        kafkaTemplate.send("category", 1, "category", afterJoiendString);
-//        kafkaTemplate.send("hashtag", 1, "hashtag", afterJoiendString2);
+        kafkaTemplate.send("category", 1, "category", afterJoiendString);
+        kafkaTemplate.send("hashtag", 1, "hashtag", afterJoiendString2);
     }
 
 
@@ -232,8 +232,8 @@ public void deleteBoard(int boardId) {
         String afterJoiendString = originalBoard.getTemperature() + "/" + String.join("/", originalBoard.getCategory());
         String afterJoiendString2 = String.join("/", originalBoard.getHashTag());
 
-//        kafkaTemplate.send("category", 2, "category", afterJoiendString);
-//        kafkaTemplate.send("hashtag", 2, "hashtag", afterJoiendString2);
+        kafkaTemplate.send("category", 2, "category", afterJoiendString);
+        kafkaTemplate.send("hashtag", 2, "hashtag", afterJoiendString2);
 
 
         boardRepository.deleteById(boardId);