Sett initial delay på liveness- og readiness-probes

Appen starter ikke opp i dev, vi håper at det er på grunn av en K8S probe som ikke får svar, og sender shutdown

Co-authored-by: John Martin Lindseth <[email protected]>

Author: vskjefst

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/subsumsjonbrukt/KafkaSubsumsjonBruktDataConsumer.kt

@@ -29,7 +29,8 @@ internal class KafkaSubsumsjonBruktDataConsumer(
     private val config: InntektApiConfig,
     private val inntektStore: InntektStore,
     private val graceDuration: Duration = Duration.ofHours(3),
-) : CoroutineScope, HealthCheck {
+) : CoroutineScope,
+    HealthCheck {
     private val logger = KotlinLogging.logger { }
     override val coroutineContext: CoroutineContext
         get() = Dispatchers.IO + job
@@ -62,7 +63,8 @@ internal class KafkaSubsumsjonBruktDataConsumer(
                     while (job.isActive) {
                         val records = consumer.poll(Duration.ofMillis(100))
                         val ids =
-                            records.asSequence()
+                            records
+                                .asSequence()
                                 .map { record -> record.value() }
                                 .map { jacksonObjectMapper.readTree(it) }
                                 .filter { packet ->
@@ -71,8 +73,7 @@ internal class KafkaSubsumsjonBruktDataConsumer(
                                         packet.has("inntektsId") &&
                                         packet.has("kontekst") &&
                                         packet.get("@event_name").asText() == "brukt_inntekt"
-                                }
-                                .map { packet -> InntektId(packet.get("inntektsId").asText()) }
+                                }.map { packet -> InntektId(packet.get("inntektsId").asText()) }
                                 .toList()
 
                         try {
@@ -104,11 +105,15 @@ internal class KafkaSubsumsjonBruktDataConsumer(
 
     override fun status(): HealthStatus {
         return if (job.isActive) {
+            logger.info("Kafka job.isActive=${job.isActive}")
             HealthStatus.UP
         } else {
+            logger.info("Kafka job.isActive=${job.isActive}")
             return if (grace.expired()) {
+                logger.info("Kafka grace.expired()=${grace.expired()}")
                 HealthStatus.DOWN
             } else {
+                logger.info("Kafka grace.expired()=${grace.expired()}")
                 HealthStatus.UP
             }
         }
@@ -138,8 +143,8 @@ internal class KafkaSubsumsjonBruktDataConsumer(
         internal fun commonConfig(
             bootstrapServers: String,
             credential: Config.KafkaAivenCredentials? = null,
-        ): Properties {
-            return Properties().apply {
+        ): Properties =
+            Properties().apply {
                 put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers)
                 credential?.let { creds ->
                     putAll(
@@ -159,19 +164,17 @@ internal class KafkaSubsumsjonBruktDataConsumer(
                     )
                 }
             }
-        }
     }
 
     private fun consumerConfig(
         groupId: String,
         bootstrapServerUrl: String,
         credential: Config.KafkaAivenCredentials? = null,
         properties: Properties = defaultConsumerConfig,
-    ): Properties {
-        return Properties().apply {
+    ): Properties =
+        Properties().apply {
             putAll(properties)
             putAll(commonConfig(bootstrapServerUrl, credential))
             put(ConsumerConfig.GROUP_ID_CONFIG, groupId)
         }
-    }
 }