diff --git a/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/TilstandsLaster.kt b/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/TilstandsLaster.kt index 2228c222..31236eab 100644 --- a/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/TilstandsLaster.kt +++ b/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/TilstandsLaster.kt @@ -36,7 +36,7 @@ class TilstandsLaster( tilstandsopprydding( requireNotNull(context) { "Context er ikke initialisert" }, requireNotNull(tilstandsDb){ "TilstandsDb er ikke initialisert" }, - Duration.ofDays(1), + Duration.ofHours(2), keepGoing ) } diff --git a/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/Tilstandsopprydding.kt b/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/Tilstandsopprydding.kt index 6a8255b0..82dbcb00 100644 --- a/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/Tilstandsopprydding.kt +++ b/apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/kafkastreamsprocessors/Tilstandsopprydding.kt @@ -22,6 +22,7 @@ fun tilstandsopprydding( stateStore.all().use { tilstander -> tilstander.asSequence().takeWhile { keepGoing.get() } .filter { it.value.skalSlettes() } + .take(10000) .onEach { tilstand -> try { stateStore.delete(tilstand.key)