[UPLUS-29] api-message 초기 구현

build.gradle

@@ -48,6 +48,9 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-validation'
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
 
+    // Kafka
+    implementation 'org.springframework.kafka:spring-kafka'
+
     // Monitoring & Observability
     implementation 'io.micrometer:micrometer-registry-prometheus'
     implementation 'net.logstash.logback:logstash-logback-encoder:7.4'
@@ -70,6 +73,7 @@ dependencies {
     // Test
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.security:spring-security-test'
+    testImplementation 'org.springframework.kafka:spring-kafka-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 }
 

src/main/java/com/project/Application.java

@@ -6,7 +6,7 @@
 @SpringBootApplication
 public class Application {
 
-  public static void main(String[] args) {
-    SpringApplication.run(Application.class, args);
-  }
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
 }

src/main/java/com/project/controller/HomeController.java

@@ -1,6 +1,7 @@
 package com.project.controller;
 
 import java.util.Map;
+
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -9,23 +10,23 @@
 @RestController
 public class HomeController {
 
-  @Value("${spring.application.name:backend}")
-  private String applicationName;
+    @Value("${spring.application.name:backend}")
+    private String applicationName;
 
-  @Value("${app.version:1.0.0}")
-  private String version;
+    @Value("${app.version:1.0.0}")
+    private String version;
 
-  @GetMapping("/")
-  public ResponseEntity<Map<String, String>> home() {
-    return ResponseEntity.ok(
-        Map.of(
-            "status",
-            "ok",
-            "message",
-            applicationName + " is running",
-            "version",
-            version,
-            "docs",
-            "/swagger-ui.html"));
-  }
+    @GetMapping("/")
+    public ResponseEntity<Map<String, String>> home() {
+        return ResponseEntity.ok(
+                Map.of(
+                        "status",
+                        "ok",
+                        "message",
+                        applicationName + " is running",
+                        "version",
+                        version,
+                        "docs",
+                        "/swagger-ui.html"));
+    }
 }

src/main/java/com/project/example/controller/ExampleController.java

@@ -1,9 +1,5 @@
 package com.project.example.controller;
 
-import com.project.example.controller.dto.SaveExampleRequest;
-import com.project.example.infra.entity.ExampleEntity;
-import com.project.example.service.ExampleService;
-import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -12,20 +8,26 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import com.project.example.controller.dto.SaveExampleRequest;
+import com.project.example.infra.entity.ExampleEntity;
+import com.project.example.service.ExampleService;
+
+import lombok.RequiredArgsConstructor;
+
 @RestController
 @RequestMapping("/example")
 @RequiredArgsConstructor
 public class ExampleController {
 
-  private final ExampleService exampleService;
+    private final ExampleService exampleService;
 
-  @GetMapping("/{exampleId}")
-  public ResponseEntity<ExampleEntity> find(@PathVariable Long exampleId) {
-    return ResponseEntity.ok(exampleService.find(exampleId));
-  }
+    @GetMapping("/{exampleId}")
+    public ResponseEntity<ExampleEntity> find(@PathVariable Long exampleId) {
+        return ResponseEntity.ok(exampleService.find(exampleId));
+    }
 
-  @PostMapping
-  public void save(@RequestBody SaveExampleRequest request) {
-    exampleService.save(request);
-  }
+    @PostMapping
+    public void save(@RequestBody SaveExampleRequest request) {
+        exampleService.save(request);
+    }
 }

src/main/java/com/project/example/infra/entity/ExampleEntity.java

@@ -1,10 +1,12 @@
 package com.project.example.infra.entity;
 
-import com.project.example.controller.dto.SaveExampleRequest;
 import jakarta.persistence.Entity;
 import jakarta.persistence.GeneratedValue;
 import jakarta.persistence.Id;
 import jakarta.persistence.Table;
+
+import com.project.example.controller.dto.SaveExampleRequest;
+
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.NoArgsConstructor;
@@ -16,16 +18,16 @@
 @AllArgsConstructor
 public class ExampleEntity {
 
-  @Id @GeneratedValue private Long exampleId;
+    @Id @GeneratedValue private Long exampleId;
 
-  private String exampleName;
+    private String exampleName;
 
-  private String exampleContent;
+    private String exampleContent;
 
-  public static ExampleEntity create(SaveExampleRequest request) {
-    return ExampleEntity.builder()
-        .exampleName(request.exampleName())
-        .exampleContent(request.exampleContent())
-        .build();
-  }
+    public static ExampleEntity create(SaveExampleRequest request) {
+        return ExampleEntity.builder()
+                .exampleName(request.exampleName())
+                .exampleContent(request.exampleContent())
+                .build();
+    }
 }

src/main/java/com/project/example/infra/repository/ExampleJpaRepository.java

@@ -1,6 +1,7 @@
 package com.project.example.infra.repository;
 
-import com.project.example.infra.entity.ExampleEntity;
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import com.project.example.infra.entity.ExampleEntity;
+
 public interface ExampleJpaRepository extends JpaRepository<ExampleEntity, Long> {}

src/main/java/com/project/example/infra/repository/ExampleRepository.java

@@ -4,7 +4,7 @@
 
 public interface ExampleRepository {
 
-  ExampleEntity find(Long exampleId);
+    ExampleEntity find(Long exampleId);
 
-  void save(ExampleEntity exampleEntity);
+    void save(ExampleEntity exampleEntity);
 }

src/main/java/com/project/example/infra/repository/ExampleRepositoryImpl.java

@@ -1,24 +1,26 @@
 package com.project.example.infra.repository;
 
+import org.springframework.stereotype.Repository;
+
 import com.project.example.infra.entity.ExampleEntity;
 import com.project.global.exception.ApplicationException;
 import com.project.global.exception.code.domain.ExampleErrorCode;
+
 import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Repository;
 
 @Repository
 @RequiredArgsConstructor
 public class ExampleRepositoryImpl implements ExampleRepository {
 
-  private final ExampleJpaRepository exampleJpaRepository;
+    private final ExampleJpaRepository exampleJpaRepository;
 
-  public ExampleEntity find(Long exampleId) {
-    return exampleJpaRepository
-        .findById(exampleId)
-        .orElseThrow(() -> new ApplicationException(ExampleErrorCode.EXAMPLE_NOT_FOUND));
-  }
+    public ExampleEntity find(Long exampleId) {
+        return exampleJpaRepository
+                .findById(exampleId)
+                .orElseThrow(() -> new ApplicationException(ExampleErrorCode.EXAMPLE_NOT_FOUND));
+    }
 
-  public void save(ExampleEntity example) {
-    exampleJpaRepository.save(example);
-  }
+    public void save(ExampleEntity example) {
+        exampleJpaRepository.save(example);
+    }
 }

src/main/java/com/project/example/service/ExampleService.java

@@ -1,26 +1,28 @@
 package com.project.example.service;
 
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
 import com.project.example.controller.dto.SaveExampleRequest;
 import com.project.example.infra.entity.ExampleEntity;
 import com.project.example.infra.repository.ExampleRepository;
+
 import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
 public class ExampleService {
 
-  private final ExampleRepository exampleRepository;
+    private final ExampleRepository exampleRepository;
 
-  @Transactional
-  public ExampleEntity find(Long exampleId) {
-    return exampleRepository.find(exampleId);
-  }
+    @Transactional
+    public ExampleEntity find(Long exampleId) {
+        return exampleRepository.find(exampleId);
+    }
 
-  @Transactional
-  public void save(SaveExampleRequest request) {
-    ExampleEntity exampleEntity = ExampleEntity.create(request);
-    exampleRepository.save(exampleEntity);
-  }
+    @Transactional
+    public void save(SaveExampleRequest request) {
+        ExampleEntity exampleEntity = ExampleEntity.create(request);
+        exampleRepository.save(exampleEntity);
+    }
 }

src/main/java/com/project/global/config/KafkaConfig.java

@@ -0,0 +1,25 @@
+package com.project.global.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.annotation.EnableKafka;
+import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
+import org.springframework.kafka.core.ConsumerFactory;
+import org.springframework.kafka.listener.ContainerProperties;
+
+@Configuration
+@EnableKafka
+public class KafkaConfig {
+
+    @Bean
+    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory(
+            ConsumerFactory<String, String> consumerFactory) {
+        ConcurrentKafkaListenerContainerFactory<String, String> factory =
+                new ConcurrentKafkaListenerContainerFactory<>();
+
+        factory.setConsumerFactory(consumerFactory);
+        factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL);
+
+        return factory;
+    }
+}

src/main/java/com/project/global/config/MetricsConfig.java

@@ -0,0 +1,73 @@
+package com.project.global.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import io.micrometer.core.instrument.Counter;
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Timer;
+
+@Configuration
+public class MetricsConfig {
+
+    @Bean
+    public Counter emailSuccessCounter(MeterRegistry registry) {
+        return Counter.builder("notification.sent.total")
+                .tag("channel", "EMAIL")
+                .tag("status", "SUCCESS")
+                .description("Total successful email notifications")
+                .register(registry);
+    }
+
+    @Bean
+    public Counter emailFailCounter(MeterRegistry registry) {
+        return Counter.builder("notification.sent.total")
+                .tag("channel", "EMAIL")
+                .tag("status", "FAIL")
+                .description("Total failed email notifications")
+                .register(registry);
+    }
+
+    @Bean
+    public Counter smsSuccessCounter(MeterRegistry registry) {
+        return Counter.builder("notification.sent.total")
+                .tag("channel", "SMS")
+                .tag("status", "SUCCESS")
+                .description("Total successful SMS notifications")
+                .register(registry);
+    }
+
+    @Bean
+    public Counter smsFailCounter(MeterRegistry registry) {
+        return Counter.builder("notification.sent.total")
+                .tag("channel", "SMS")
+                .tag("status", "FAIL")
+                .description("Total failed SMS notifications")
+                .register(registry);
+    }
+
+    @Bean
+    public Counter smsFallbackCounter(MeterRegistry registry) {
+        return Counter.builder("notification.sent.total")
+                .tag("channel", "SMS")
+                .tag("status", "FALLBACK")
+                .description("Total SMS fallback notifications")
+                .register(registry);
+    }
+
+    @Bean
+    public Timer emailProcessingTimer(MeterRegistry registry) {
+        return Timer.builder("notification.processing.time")
+                .tag("channel", "EMAIL")
+                .description("Email notification processing time")
+                .register(registry);
+    }
+
+    @Bean
+    public Timer smsProcessingTimer(MeterRegistry registry) {
+        return Timer.builder("notification.processing.time")
+                .tag("channel", "SMS")
+                .description("SMS notification processing time")
+                .register(registry);
+    }
+}

src/main/java/com/project/global/config/RedisConfig.java

@@ -10,14 +10,14 @@
 @Configuration
 public class RedisConfig {
 
-  @Bean
-  public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
-    RedisTemplate<String, Object> template = new RedisTemplate<>();
-    template.setConnectionFactory(connectionFactory);
-    template.setKeySerializer(new StringRedisSerializer());
-    template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
-    template.setHashKeySerializer(new StringRedisSerializer());
-    template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
-    return template;
-  }
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(connectionFactory);
+        template.setKeySerializer(new StringRedisSerializer());
+        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+        template.setHashKeySerializer(new StringRedisSerializer());
+        template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
+        return template;
+    }
 }