Unverified Commit 7d06da03 authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

reduce max poll records


Signed-off-by: Sebastian Schüpbach's avatarSebastian Schüpbach <sebastian.schuepbach@unibas.ch>
parent 0982b7c7
Pipeline #22257 passed with stages
in 4 minutes and 59 seconds
/* /*
* Import Process Delete * Import Process Delete
* Copyright (C) 2020 Memoriav * Copyright (C) 2021 Memoriav
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by * it under the terms of the GNU Affero General Public License as published by
...@@ -19,7 +19,6 @@ ...@@ -19,7 +19,6 @@
package ch.memobase package ch.memobase
import java.util.Properties import java.util.Properties
import scala.util.Random import scala.util.Random
trait AppSettings { trait AppSettings {
...@@ -45,7 +44,7 @@ trait AppSettings { ...@@ -45,7 +44,7 @@ trait AppSettings {
props.put("group.id", clientId) props.put("group.id", clientId)
props.put("allow.auto.create.topics", "false") props.put("allow.auto.create.topics", "false")
props.put("auto.offset.reset", "earliest") props.put("auto.offset.reset", "earliest")
props.put("max.poll.records", "5000") props.put("max.poll.records", "500")
props props
} }
} }
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment