[LB-461] 트레이싱 설정

build.gradle

@@ -5,7 +5,7 @@ plugins {
 }
 
 group = 'com.lgcms'
-version = '0.1'
+version = '0.2'
 
 java {
 	toolchain {
@@ -42,6 +42,10 @@ dependencies {
 
 	implementation 'org.springframework.boot:spring-boot-starter-actuator'
 	runtimeOnly 'io.micrometer:micrometer-registry-prometheus'
+
+	implementation 'io.micrometer:micrometer-tracing-bridge-otel' // 트레이싱
+	implementation 'io.opentelemetry:opentelemetry-exporter-otlp' // otel exporter
+	implementation 'io.github.openfeign:feign-micrometer' // feign 트레이싱
 }
 
 dependencyManagement {

src/main/java/com/lgcms/streaming/config/KafkaConfig.java

@@ -0,0 +1,9 @@
+package com.lgcms.streaming.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.annotation.EnableKafka;
+
+@Configuration
+@EnableKafka
+public class KafkaConfig {
+}

src/main/java/com/lgcms/streaming/config/ObjectMapperConfig.java

@@ -0,0 +1,15 @@
+package com.lgcms.streaming.config;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ObjectMapperConfig {
+    @Bean
+    public ObjectMapper objectMapper() {
+        return new ObjectMapper()
+            .registerModule(new JavaTimeModule());
+    }
+}

src/main/java/com/lgcms/streaming/event/consumer/EncodingConsumeService.java

@@ -18,7 +18,7 @@ public class EncodingConsumeService {
     private final StreamingService streamingService;
     private final KafkaEventFactory kafkaEventFactory;
 
-    @KafkaListener(topics = "ENCODING",containerFactory = "defaultFactory")
+    @KafkaListener(topics = "ENCODING")
     public void EncodingEvent(KafkaEvent<?> event){
         LectureEncodeDto lectureEncodeDto = kafkaEventFactory.convert(event, LectureEncodeDto.class);
 

src/main/resources/application-local.yml

@@ -12,28 +12,31 @@ spring:
 
   kafka:
     bootstrap-servers: localhost:38123
-
+    template:
+      observation-enabled: true
     listener:
-      ack-mode: manual_immediate
+      observation-enabled: true
+      ack-mode: manual
 
     consumer:
       group-id: ${spring.application.name}
-      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
+      key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
+      value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
       enable-auto-commit: false
-      auto-offset-reset: latest
+      auto-offset-reset: earliest
       max-poll-records: 10
       properties:
+        spring.deserializer.key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer
+        spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
         spring.json.trusted.packages: "*"
         spring.json.use.type.headers: false
+        spring.json.value.default.type: com.lgcms.streaming.common.kafka.dto.KafkaEvent
 
     producer:
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
       value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
       properties:
         spring.json.add.type.headers: false
-
-
 cloud:
   aws:
     s3: