set up kafka

build.gradle.kts

@@ -14,6 +14,7 @@ dependencies {
     implementation(hlaeja.kotlinx.coroutines)
     implementation(hlaeja.library.common.messages)
     implementation(hlaeja.library.jwt)
+    implementation(hlaeja.springboot.kafka)
     implementation(hlaeja.springboot.starter.actuator)
     implementation(hlaeja.springboot.starter.r2dbc)
     implementation(hlaeja.springboot.starter.security)
@@ -28,6 +29,7 @@ dependencies {
     testImplementation(hlaeja.projectreactor.reactor.test)
     testImplementation(hlaeja.kotlin.test.junit5)
     testImplementation(hlaeja.kotlinx.coroutines.test)
+    testImplementation(hlaeja.springboot.kafka.test)
     testImplementation(hlaeja.springboot.starter.test)
 
     testRuntimeOnly(hlaeja.junit.platform.launcher)
@@ -37,6 +39,7 @@ dependencies {
     testIntegrationImplementation(hlaeja.projectreactor.reactor.test)
     testIntegrationImplementation(hlaeja.kotlin.test.junit5)
     testIntegrationImplementation(hlaeja.kotlinx.coroutines.test)
+    testIntegrationImplementation(hlaeja.springboot.kafka.test)
     testIntegrationImplementation(hlaeja.springboot.starter.test)
 
     testIntegrationRuntimeOnly(hlaeja.junit.platform.launcher)

gradle.properties

@@ -1,4 +1,4 @@
 kotlin.code.style=official
 version=0.4.0-SNAPSHOT
-catalog=0.11.0
+catalog=0.12.0-SNAPSHOT
 container.port.host=9050

src/main/resources/application.yml

@@ -11,6 +11,9 @@ spring:
         version: "%APP_BUILD_OS_VERSION%"
   r2dbc:
     username: services
+  kafka:
+    producer:
+      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
 
 management:
   endpoints:
@@ -40,6 +43,8 @@ spring:
   r2dbc:
     url: r2dbc:postgresql://localhost:5432/account_registry
     password: password
+  kafka:
+    bootstrap-servers: localhost:9091
 
 ---
 ##########################
@@ -52,6 +57,8 @@ spring:
   r2dbc:
     url: r2dbc:postgresql://PostgreSQL:5432/account_registry
     password: password
+  kafka:
+    bootstrap-servers: kafka:9092
 
 ---
 ##############################