Justerte max poll records og poll timeout for key maintenance

nilsmsa · nilsmsa · commit a92d7c97d2e5 · 2024-11-14T12:57:17.000+01:00
diff --git a/apps/kafka-key-maintenance/src/main/kotlin/no/nav/paw/kafkakeymaintenance/InitPeriodeConsumer.kt b/apps/kafka-key-maintenance/src/main/kotlin/no/nav/paw/kafkakeymaintenance/InitPeriodeConsumer.kt
@@ -19,13 +19,14 @@ fun KafkaFactory.initPeriodeConsumer(
         keyDeserializer = LongDeserializer::class,
         valueDeserializer = PeriodeDeserializer::class,
         autoCommit = false,
-        autoOffsetReset = "earliest"
+        autoOffsetReset = "earliest",
+        maxPollrecords = 1000
     )
     val reblancingListener = HwmRebalanceListener(applicationContext, periodeConsumer)
     periodeConsumer.subscribe(listOf(periodeTopic))
     return reblancingListener to periodeConsumer.asSequence(
         stop = applicationContext.shutdownCalled,
-        pollTimeout = Duration.ofMillis(500),
+        pollTimeout = Duration.ofMillis(1000),
         closeTimeout = Duration.ofSeconds(1)
     )
 }

Original file line number	Diff line number	Diff line change
`@@ -19,13 +19,14 @@ fun KafkaFactory.initPeriodeConsumer(`
`19`	`19`	`keyDeserializer = LongDeserializer::class,`
`20`	`20`	`valueDeserializer = PeriodeDeserializer::class,`
`21`	`21`	`autoCommit = false,`
`22`		`- autoOffsetReset = "earliest"`
	`22`	`+ autoOffsetReset = "earliest",`
	`23`	`+ maxPollrecords = 1000`
`23`	`24`	`)`
`24`	`25`	`val reblancingListener = HwmRebalanceListener(applicationContext, periodeConsumer)`
`25`	`26`	`periodeConsumer.subscribe(listOf(periodeTopic))`
`26`	`27`	`return reblancingListener to periodeConsumer.asSequence(`
`27`	`28`	`stop = applicationContext.shutdownCalled,`
`28`		`- pollTimeout = Duration.ofMillis(500),`
	`29`	`+ pollTimeout = Duration.ofMillis(1000),`
`29`	`30`	`closeTimeout = Duration.ofSeconds(1)`
`30`	`31`	`)`
`31`	`32`	`}`