Merge pull request #96 from soma-baekgu/feature/BG-349-kafka-record-p…

…artitioning

[BG-349]: Kafka 파티셔너에서 알림 순서를 유지하는 형태로 파티셔닝 되도록 수정 (1h / 1h)

domain/src/main/kotlin/com/backgu/amaker/domain/notifiacation/Notification.kt

@@ -5,4 +5,10 @@ import java.io.Serializable
 
 interface Notification : Serializable {
     val method: NotificationMethod
+    val keyPrefix: String
+    val keyValue: String
+
+    fun getNotificationKey(): String {
+        return "$keyPrefix:$keyValue"
+    }
 }

domain/src/main/kotlin/com/backgu/amaker/domain/notifiacation/PushNotification.kt

@@ -6,4 +6,10 @@ import com.backgu.amaker.domain.user.UserDevice
 class PushNotification(
     override val method: NotificationMethod,
     val userDevices: List<UserDevice>,
-) : Notification
+) : Notification {
+    override val keyPrefix: String
+        get() = "PUSH"
+
+    override val keyValue: String
+        get() = userDevices.first().userId
+}

domain/src/main/kotlin/com/backgu/amaker/domain/notifiacation/UserFulfilledNotification.kt

@@ -6,4 +6,10 @@ import com.backgu.amaker.domain.user.User
 class UserFulfilledNotification(
     val user: User,
     override val method: RealTimeNotificationMethod,
-) : RealTimeBasedNotification(method)
+) : RealTimeBasedNotification(method) {
+    override val keyPrefix: String
+        get() = "USER"
+
+    override val keyValue: String
+        get() = user.id
+}

domain/src/main/kotlin/com/backgu/amaker/domain/notifiacation/UserNotification.kt

@@ -5,4 +5,10 @@ import com.backgu.amaker.domain.notifiacation.method.RealTimeNotificationMethod
 open class UserNotification(
     val userId: String,
     override val method: RealTimeNotificationMethod,
-) : RealTimeBasedNotification(method)
+) : RealTimeBasedNotification(method) {
+    override val keyPrefix: String
+        get() = "USER"
+
+    override val keyValue: String
+        get() = userId
+}

domain/src/main/kotlin/com/backgu/amaker/domain/notifiacation/WorkspaceNotification.kt

@@ -5,4 +5,10 @@ import com.backgu.amaker.domain.notifiacation.method.RealTimeNotificationMethod
 open class WorkspaceNotification(
     open val workspaceId: Long,
     override val method: RealTimeNotificationMethod,
-) : RealTimeBasedNotification(method)
+) : RealTimeBasedNotification(method) {
+    override val keyPrefix: String
+        get() = "WORKSPACE"
+
+    override val keyValue: String
+        get() = workspaceId.toString()
+}

infra/src/main/kotlin/com/backgu/amaker/infra/notification/kafka/service/KafkaNotificationEventService.kt

@@ -9,6 +9,6 @@ class KafkaNotificationEventService(
     private val kafkaTemplate: KafkaTemplate<String, Notification>,
 ) : NotificationEventService {
     override fun publishNotificationEvent(notification: Notification) {
-        kafkaTemplate.send(KafkaConfig.NOTIFICATION_TOPIC, notification)
+        kafkaTemplate.send(KafkaConfig.NOTIFICATION_TOPIC, notification.getNotificationKey(), notification)
     }
 }