kafka message 클래스 생성

src/main/java/com/github/deogicorgi/reactor/kafka/exception/ProducerServiceException.java

@@ -0,0 +1,7 @@
+package com.github.deogicorgi.reactor.kafka.exception;
+
+public class ProducerServiceException extends Exception{
+    public ProducerServiceException(Exception e) {
+        super(e);
+    }
+}

src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/AbstractKafkaProduceMessage.java

@@ -0,0 +1,19 @@
+package com.github.deogicorgi.reactor.kafka.producer.message;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.github.deogicorgi.reactor.kafka.exception.ProducerServiceException;
+
+public abstract class AbstractKafkaProduceMessage {
+
+    protected String message;
+
+    public void setMessage(Object message) throws ProducerServiceException {
+        ObjectMapper objectMapper = new ObjectMapper();
+        try {
+            this.message = objectMapper.writeValueAsString(message);
+        } catch (Exception e) {
+            throw new ProducerServiceException(e);
+        }
+
+    }
+}

src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java

@@ -0,0 +1,4 @@
+package com.github.deogicorgi.reactor.kafka.producer.message;
+
+public class KafkaProduceMessage extends AbstractKafkaProduceMessage {
+}