set up Kafka

build.gradle.kts

@@ -16,6 +16,7 @@ dependencies {
     implementation(hlaeja.library.common.messages)
     implementation(hlaeja.library.jwt)
     implementation(hlaeja.projectreactor.kotlin.reactor.extensions)
+    implementation(hlaeja.springboot.kafka)
     implementation(hlaeja.springboot.redis.session)
     implementation(hlaeja.springboot.starter.actuator)
     implementation(hlaeja.springboot.starter.redis)
@@ -29,6 +30,7 @@ dependencies {
     testImplementation(hlaeja.kotlin.test.junit5)
     testImplementation(hlaeja.mockk)
     testImplementation(hlaeja.projectreactor.reactor.test)
+    testImplementation(hlaeja.springboot.kafka.test)
     testImplementation(hlaeja.springboot.starter.test)
 
     testRuntimeOnly(hlaeja.junit.platform.launcher)

src/main/resources/application.yml

@@ -17,6 +17,13 @@ spring:
     redis:
       port: 6379
       database: 2
+  kafka:
+    consumer:
+      group-id: management-ui
+      auto-offset-reset: latest
+      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
+      properties:
+        spring.json.trusted.packages: "ltd.hlaeja.library.accountRegistry.event"
 
 server:
   error:
@@ -63,6 +70,8 @@ spring:
   data:
     redis:
       host: localhost
+  kafka:
+    bootstrap-servers: localhost:9091
 
 server:
   error:
@@ -89,6 +98,8 @@ spring:
   data:
     redis:
       host: Redis
+  kafka:
+    bootstrap-servers: kafka:9092
 
 server:
   error:

src/main/resources/logback-spring.xml

@@ -7,7 +7,7 @@
   <root level="INFO">
     <appender-ref ref="STDOUT"/>
   </root>
-  <springProfile name="develop|docker">
-    <logger level="DEBUG" name="ltd.hlaeja"/>
+  <springProfile name="development|docker">
+    <logger level="TRACE" name="ltd.hlaeja"/>
   </springProfile>
 </configuration>