More memory

navikt · Dec 20, 2024 · d41a648 · d41a648
1 parent bf78432
commit d41a648
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/.nais/ebms-provider-dev.yaml b/.nais/ebms-provider-dev.yaml
@@ -45,7 +45,7 @@ spec:
   resources:
     limits:
       cpu: "1000m"
-      memory: "512Mi"
+      memory: "1024Mi"
     requests:
       cpu: "100m"
       memory: "256Mi"

diff --git a/ebms-provider/src/main/kotlin/no/nav/emottak/ebms/App.kt b/ebms-provider/src/main/kotlin/no/nav/emottak/ebms/App.kt
@@ -31,7 +31,6 @@ import io.micrometer.prometheus.PrometheusConfig
 import io.micrometer.prometheus.PrometheusMeterRegistry
 import kotlinx.coroutines.awaitCancellation
 import kotlinx.coroutines.flow.map
-import kotlinx.coroutines.flow.take
 import kotlinx.coroutines.launch
 import net.logstash.logback.marker.Markers
 import no.nav.emottak.constants.SMTPHeaders
@@ -111,7 +110,6 @@ suspend fun startSignalReceiver(kafka: Kafka) {
     val signalProcessor = SignalProcessor()
     KafkaReceiver(receiverSettings)
         .receive(kafka.incomingSignalTopic)
-        .take(20)
         .map { record ->
             signalProcessor.processSignal(record.key(), record.value())
             record