Enable Kafka consumers (#289)

navikt · Jan 11, 2024 · bca9229 · bca9229
1 parent fae654d
commit bca9229
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/src/main/kotlin/no/nav/syfo/dialogmote/kafka/DialogmoteStatusendringListener.kt b/src/main/kotlin/no/nav/syfo/dialogmote/kafka/DialogmoteStatusendringListener.kt
@@ -8,15 +8,17 @@ import org.slf4j.LoggerFactory
 import org.springframework.context.annotation.Profile
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.kafka.support.Acknowledgment
+import org.springframework.stereotype.Component
 
 @Profile("remote")
+@Component
 class DialogmoteStatusendringListener(
-    private val dialogmoteStatusService: DialogmoteStatusService,
+    private val dialogmoteStatusService: DialogmoteStatusService
 ) {
     @KafkaListener(topics = [DIALOGMOTE_STATUSENDRING_TOPIC], containerFactory = "DialogmoteListenerContainerFactory")
     fun dialogmoteStatusEndringListener(
         consumerRecord: ConsumerRecord<String, KDialogmoteStatusEndring>,
-        acknowledgment: Acknowledgment,
+        acknowledgment: Acknowledgment
     ) {
         LOG.info("Got record from $DIALOGMOTE_STATUSENDRING_TOPIC topic for dialogmoteUuid: ${consumerRecord.value().getDialogmoteUuid()}")
         try {

diff --git a/src/main/kotlin/no/nav/syfo/dialogmotekandidat/kafka/DialogmotekandidatListener.kt b/src/main/kotlin/no/nav/syfo/dialogmotekandidat/kafka/DialogmotekandidatListener.kt
@@ -7,8 +7,10 @@ import org.slf4j.LoggerFactory
 import org.springframework.context.annotation.Profile
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.kafka.support.Acknowledgment
+import org.springframework.stereotype.Component
 
 @Profile("remote")
+@Component
 class DialogmotekandidatListener(
     private val dialogmotekandidatService: DialogmotekandidatService
 ) {

diff --git a/src/main/kotlin/no/nav/syfo/oppfolgingstilfelle/kafka/IsOppfolgingstilfelleListener.kt b/src/main/kotlin/no/nav/syfo/oppfolgingstilfelle/kafka/IsOppfolgingstilfelleListener.kt
@@ -8,8 +8,10 @@ import org.slf4j.LoggerFactory
 import org.springframework.context.annotation.Profile
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.kafka.support.Acknowledgment
+import org.springframework.stereotype.Component
 
 @Profile("remote")
+@Component
 class IsOppfolgingstilfelleListener(
     private val oppfolgingstilfelleService: OppfolgingstilfelleService
 ) {