sett big leap til 4000 som tilsvarer ca 2 dager med dagens volum

navikt · Dec 6, 2024 · 3d1bbaf · 3d1bbaf
1 parent abafc78
commit 3d1bbaf
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/DEVELOPMENT.md b/DEVELOPMENT.md
@@ -83,7 +83,7 @@ List alle consumer groups på fager.notifikasjon topic:
 
 List offsets for en consumer group (fra listen over consumer groups):
 ```
-./kafka-consumer-groups.sh --bootstrap-server $KAFKA_BROKERS --command-config $KAFKA_CONFIG/kafka.properties --group bruker-model-builder --describe
+.kafka-cli/bin/kafka-consumer-groups.sh --bootstrap-server $KAFKA_BROKERS --command-config $KAFKA_CONFIG/kafka.properties --group bruker-model-builder --describe
 ```
 
 Dersom man skal endre en offset på en partisjon må consumer group være inaktiv. Dette gjøres enklest ved å skalere ned deployment til 0:
@@ -103,13 +103,13 @@ kubectl scale --replicas=1 deployment/notifikasjon-dataprodukt
 
 Hopp over en offset på en gitt partisjon for en consumer group:
 ```
-./kafka-consumer-groups.sh --bootstrap-server $KAFKA_BROKERS --command-config $KAFKA_CONFIG/kafka.properties --group bruker-model-builder --topic fager.notifikasjon:12 --reset-offsets --shift-by 1 --execute
+.kafka-cli/bin/kafka-consumer-groups.sh --bootstrap-server $KAFKA_BROKERS --command-config $KAFKA_CONFIG/kafka.properties --group bruker-model-builder --topic fager.notifikasjon:12 --reset-offsets --shift-by 1 --execute
 ```
 
 
 Les topic for en gitt partisjon fra et gitt offset:
 ```
-.kafka-cli/bin/./kafka-console-consumer.sh --bootstrap-server $KAFKA_BROKERS --consumer.config $KAFKA_CONFIG/kafka.properties --topic fager.notifikasjon --formatter kafka.tools.DefaultMessageFormatter --property print.value=true --property print.offset=true --partition 12 --offset 124
+.kafka-cli/bin/kafka-console-consumer.sh --bootstrap-server $KAFKA_BROKERS --consumer.config $KAFKA_CONFIG/kafka.properties --topic fager.notifikasjon --formatter kafka.tools.DefaultMessageFormatter --property print.value=true --property print.offset=true --partition 12 --offset 124
 ```
 
 Describe topic:

diff --git a/...ain/kotlin/no/nav/arbeidsgiver/notifikasjon/infrastruktur/kafka/CoroutineKafkaConsumer.kt b/...ain/kotlin/no/nav/arbeidsgiver/notifikasjon/infrastruktur/kafka/CoroutineKafkaConsumer.kt
@@ -104,7 +104,7 @@ private constructor(
         consumer,
         isBigLeap = { t -> t.hour == 5 && t.minute == 0 },
         isSmallLeap = { t -> t.minute == 0 },
-        bigLeap = 10_000,
+        bigLeap = 4_000,
         smallLeap = 100,
         enabled = replayPeriodically,
     )