Scale up pods after migration (#288)

* Scale up pods after migration * Disable Kafka consumers --------- Co-authored-by: Kaja Kvinge Akselsen <[email protected]>
navikt · Jan 11, 2024 · fae654d · fae654d
1 parent 9eb4bc1
commit fae654d
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 12 deletions.
diff --git a/nais/nais-dev.yaml b/nais/nais-dev.yaml
@@ -30,8 +30,8 @@ spec:
       cpu: 100m
       memory: 256Mi
   replicas:
-    min: 0
-    max: 0
+    min: 2
+    max: 4
     cpuThresholdPercentage: 80
   prometheus:
     enabled: true

diff --git a/nais/nais-prod.yaml b/nais/nais-prod.yaml
@@ -30,8 +30,8 @@ spec:
       cpu: 100m
       memory: 512Mi
   replicas:
-    min: 0
-    max: 0
+    min: 2
+    max: 4
     cpuThresholdPercentage: 80
   prometheus:
     enabled: true

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,17 +8,15 @@ 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,10 +7,8 @@ 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,10 +8,8 @@ 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
 ) {