refactor: 재시도를 위한 retryCount 필드 추가

Author: ss7622

src/main/java/org/scoula/domain/cloudwatch/dto/Common.java

@@ -11,4 +11,5 @@ public class Common {
     private String memberId;
     private String ledgerCode;
     private String transactionGroupId;
+    private Integer retryCount;
 }

src/main/java/org/scoula/domain/cloudwatch/service/LogConsumerService.java

@@ -1,9 +1,10 @@
 package org.scoula.domain.cloudwatch.service;
 
+import org.scoula.domain.cloudwatch.dto.LogMessage;
 import org.springframework.stereotype.Service;
 
 @Service
 public interface LogConsumerService {
 
-	void loggingIntegration(String message) throws Exception;
+	void loggingIntegration(LogMessage message) throws Exception;
 }

src/main/java/org/scoula/domain/cloudwatch/serviceImpl/LogConsumerServiceImpl.java

@@ -29,9 +29,7 @@ public class LogConsumerServiceImpl implements LogConsumerService {
 	private static final String LOG_GROUP = "Dolfin";
 
 	@Override
-	public void loggingIntegration(String message) throws Exception {
-
-		LogMessage logMessage = objectMapper.readValue(message, LogMessage.class);
+	public void loggingIntegration(LogMessage logMessage) throws Exception {
 		String logStream = "dolfin-log-stream";
 		writeToCloudWatch(logMessage, logStream);
 	}

src/main/java/org/scoula/domain/kafka/listener/KafkaLogListener.java

@@ -1,5 +1,7 @@
 package org.scoula.domain.kafka.listener;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.scoula.domain.cloudwatch.dto.LogMessage;
 import org.scoula.domain.cloudwatch.service.LogConsumerService;
 import org.scoula.domain.kafka.producer.KafkaProducer;
 import org.springframework.kafka.annotation.KafkaListener;
@@ -16,11 +18,14 @@ public class KafkaLogListener {
 
 	private final LogConsumerService logConsumerService;
 	private final KafkaProducer kafkaProducer;
+	private final ObjectMapper objectMapper = new ObjectMapper();
+
 
 	@KafkaListener(topics = "log-module", groupId = "log-consumer-group")
 	public void listen(String message, Acknowledgment ack) {
 		try {
-			logConsumerService.loggingIntegration(message);
+			LogMessage logMessage = objectMapper.readValue(message, LogMessage.class);
+			logConsumerService.loggingIntegration(logMessage);
 			ack.acknowledge();
 		}catch (Exception e) {
 			log.error(e.getMessage());
@@ -32,7 +37,9 @@ public void listen(String message, Acknowledgment ack) {
 	@KafkaListener(topics = "log-retry", groupId = "log-retry-group")
 	public void listenRetry(String message, Acknowledgment ack) {
 		try {
-			logConsumerService.loggingIntegration(message);
+			LogMessage logMessage = objectMapper.readValue(message, LogMessage.class);
+			//todo retry count > 10 have to go DLQ
+			logConsumerService.loggingIntegration(logMessage);
 			ack.acknowledge();
 		}catch (Exception e) {
 			log.error(e.getMessage());