Feat: consumers, producers 추가

Author: skyeong42

src/main/java/cmf/commitField/global/kafka/Consumers.java

@@ -0,0 +1,26 @@
+package cmf.commitField.global.kafka;
+
+import cmf.commitField.domain.chat.chatMessage.entity.ChatMsg;
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.messaging.handler.annotation.Payload;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Component
+@RequiredArgsConstructor
+public class Consumers {
+    private final Logger logger = LoggerFactory.getLogger(Consumers.class);
+
+    public void consume(@Payload ChatMsg chatMsg) throws Exception {
+        logger.info("Consume msg : roomId : '{}', nickname :'{}', sender : '{}' ",
+                chatMsg.getId(), chatMsg.getUser().getNickname(), chatMsg.getMessage());
+        Map<String, String> msg = new HashMap<>();
+        msg.put("roomNum", String.valueOf(chatMsg.getChatRoom().getId()));
+        msg.put("message", chatMsg.getMessage());
+        msg.put("sender", chatMsg.getUser().getNickname());
+    }
+}

src/main/java/cmf/commitField/global/kafka/Producers.java

@@ -0,0 +1,20 @@
+package cmf.commitField.global.kafka;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class Producers {
+    private final Logger logger = LoggerFactory.getLogger(Producers.class);
+//    private final KafkaTemplate<String, String> kafkaTemplate;
+
+    public void produceMessage(String topic, String payload) {
+        logger.info("Topic : '{}' to Payload : '{}'", topic, payload);
+
+    }
+}