temporary

Author: dlsrks1021

backend/build.gradle

@@ -54,6 +54,9 @@ dependencies {
 	testImplementation 'org.testcontainers:junit-jupiter'
 	testImplementation "com.redis:testcontainers-redis:2.2.4"
 
+	/* KAFKA */
+	implementation 'org.springframework.kafka:spring-kafka'
+
 	/* ETC */
 	implementation 'org.apache.commons:commons-lang3:3.12.0'
 	annotationProcessor 'org.projectlombok:lombok'

backend/src/main/java/io/f1/backend/global/config/KafkaConfig.java

@@ -0,0 +1,34 @@
+package io.f1.backend.global.config;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.common.serialization.StringSerializer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.annotation.EnableKafka;
+import org.springframework.kafka.core.DefaultKafkaProducerFactory;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.kafka.core.ProducerFactory;
+
+@EnableKafka
+@Configuration
+public class KafkaConfig {
+
+    @Bean
+    public ProducerFactory<String, String> producerFactory() {
+        Map<String, Object> properties = new HashMap<>();
+
+        properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
+        properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+        properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+
+        return new DefaultKafkaProducerFactory<>(properties);
+    }
+
+    @Bean
+    public KafkaTemplate<String, String> kafkaTemplate() {
+        return new KafkaTemplate<>(producerFactory());
+    }
+}

backend/src/main/java/io/f1/backend/global/util/kafka/KafkaProducer.java

@@ -0,0 +1,31 @@
+package io.f1.backend.global.util.kafka;
+
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Component;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class KafkaProducer {
+
+    private final KafkaTemplate<String, String> kafkaTemplate;
+
+    public void send(String topic, Object object) {
+        ObjectMapper om = new ObjectMapper();
+        String jsonMessage = null;
+
+        try {
+            jsonMessage = om.writeValueAsString(object);
+        } catch (JsonProcessingException e) {
+            log.error("KafkaProducer Json Processing error, topic={}", topic, e);
+        }
+
+        kafkaTemplate.send(topic, jsonMessage);
+    }
+
+}

backend/src/main/java/io/f1/backend/global/util/kafka/connect/Field.java

@@ -0,0 +1,10 @@
+package io.f1.backend.global.util.kafka.connect;
+
+import lombok.AllArgsConstructor;
+
+@AllArgsConstructor
+public class Field {
+    private String type;
+    private boolean optional;
+    private String field;
+}

backend/src/main/java/io/f1/backend/global/util/kafka/connect/Schema.java

@@ -0,0 +1,15 @@
+package io.f1.backend.global.util.kafka.connect;
+
+import java.util.List;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public class Schema {
+    private String type;
+    private List<Field> fields;
+    private boolean optional;
+    private String name;
+}