set max records to 1

navikt · Feb 1, 2022 · 7c83fcc · 7c83fcc
1 parent b358bb1
commit 7c83fcc
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 6 deletions.
diff --git a/.github/workflows/deploy-dev.yaml b/.github/workflows/deploy-dev.yaml
@@ -1,8 +1,11 @@
 name: Deploy (dev)
 
+# on:
+#   push:
+#     branches: [dev]
 on:
   push:
-    branches: [dev]
+    branches: [feature/tc-273-adjust-kafka-for-arena]
 
 env:
   IMAGE_TAG: ${{ github.sha }}

diff --git a/backend/src/main/kotlin/no/nav/mulighetsrommet/api/kafka/KafkaFactory.kt b/backend/src/main/kotlin/no/nav/mulighetsrommet/api/kafka/KafkaFactory.kt
@@ -6,7 +6,6 @@ import no.nav.common.kafka.consumer.KafkaConsumerClient
 import no.nav.common.kafka.consumer.util.KafkaConsumerClientBuilder
 import no.nav.common.kafka.consumer.util.deserializer.Deserializers.stringDeserializer
 import no.nav.common.kafka.util.KafkaPropertiesBuilder
-import no.nav.common.kafka.util.KafkaPropertiesPreset
 import no.nav.mulighetsrommet.api.database.DatabaseFactory
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.apache.kafka.common.serialization.ByteArrayDeserializer
@@ -50,7 +49,17 @@ class KafkaFactory(private val db: DatabaseFactory) {
                 .withDeserializers(ByteArrayDeserializer::class.java, ByteArrayDeserializer::class.java)
                 .build()
         } else {
-            KafkaPropertiesPreset.aivenDefaultConsumerProperties(consumerGroupId)
+            // KafkaPropertiesPreset.aivenDefaultConsumerProperties(consumerGroupId)
+            KafkaPropertiesBuilder.consumerBuilder()
+                .withBaseProperties(1)
+                .withConsumerGroupId(consumerGroupId)
+                .withAivenBrokerUrl()
+                .withAivenAuth()
+                .withDeserializers(
+                    ByteArrayDeserializer::class.java,
+                    ByteArrayDeserializer::class.java
+                )
+                .build()
         }
     }
 

diff --git a/backend/src/test/kotlin/no/nav/mulighetsrommet/api/ApplicationTest.kt b/backend/src/test/kotlin/no/nav/mulighetsrommet/api/ApplicationTest.kt
@@ -1,9 +1,10 @@
 package no.nav.mulighetsrommet.api
 
 import io.kotest.core.spec.style.FunSpec
-import io.ktor.application.*
-import io.ktor.http.*
-import io.ktor.server.testing.*
+import io.ktor.application.Application
+import io.ktor.http.HttpMethod
+import io.ktor.server.testing.handleRequest
+import io.ktor.server.testing.withTestApplication
 import kotlin.test.assertEquals
 
 class ApplicationTest : FunSpec({