Merge pull request #5 from HRV-Mart/Added_kafka_supoprt_for_deleting_…

…user Added kafka supoprt for deleting user
HRV-Mart · Mar 28, 2023 · f5a52f6 · f5a52f6
2 parents 7c9468f + 58b32fc
commit f5a52f6
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 3 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -9,7 +9,7 @@ plugins {
 }
 
 group = "com.hrv.mart"
-version = "0.0.2"
+version = "0.0.1"
 java.sourceCompatibility = JavaVersion.VERSION_17
 
 repositories {

diff --git a/src/main/kotlin/com/hrv/mart/userlibrary/UserProducer.kt b/src/main/kotlin/com/hrv/mart/userlibrary/UserProducer.kt
@@ -10,9 +10,15 @@ class UserProducer (
     private val kafkaTemplate: KafkaTemplate<String, User>
 ) {
     fun createUser(user: User) {
+        sendMessage(user, UserTopics.createUserTopic)
+    }
+    fun deleteUser(userId: String) {
+        sendMessage(userId, UserTopics.deleteUserTopic)
+    }
+    private fun <T : Any> sendMessage(data: T, topic: String) {
         val message = MessageBuilder
-            .withPayload(user)
-            .setHeader(KafkaHeaders.TOPIC, UserTopics.createUserTopic)
+            .withPayload(data)
+            .setHeader(KafkaHeaders.TOPIC, topic)
             .build()
         kafkaTemplate.send(message)
     }

diff --git a/src/main/kotlin/com/hrv/mart/userlibrary/UserTopics.kt b/src/main/kotlin/com/hrv/mart/userlibrary/UserTopics.kt
@@ -3,5 +3,6 @@ package com.hrv.mart.userlibrary
 class UserTopics {
     companion object {
         const val createUserTopic = "CREATE_USER_TOPIC"
+        const val deleteUserTopic = "DELETE_USER_TOPIC"
     }
 }