diff --git a/src/main/java/com/github/deogicorgi/reactor/kafka/exception/ProducerServiceException.java b/src/main/java/com/github/deogicorgi/reactor/kafka/exception/ProducerServiceException.java
new file mode 100644
index 0000000..02a3938
--- /dev/null
+++ b/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);
+    }
+}
diff --git a/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/AbstractKafkaProduceMessage.java b/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/AbstractKafkaProduceMessage.java
new file mode 100644
index 0000000..64d5041
--- /dev/null
+++ b/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);
+        }
+
+    }
+}
diff --git a/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java b/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java
new file mode 100644
index 0000000..540ece3
--- /dev/null
+++ b/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 {
+}