Commit b58ad288 authored by Thomas Bernhart's avatar Thomas Bernhart
Browse files

MEMO-740: Set max.poll.interval.ms to 3600000 (1 hour)

parent a080c816
Pipeline #15126 passed with stages
in 5 minutes and 9 seconds
......@@ -33,6 +33,7 @@ class Service(fileName: String = "app.yml") : Closeable {
companion object {
const val FEDORA_PROPERTIES_PREFIX = "fedora"
const val CONSUMER_MAX_POLL_RECORDS = "10"
const val CONSUMER_MAX_INTERVAL_MS = "3600000" // 3600000ms = 1h
fun createFedoraClient(appSettings: Properties): FedoraClient {
return FedoraClientImpl.builder()
......@@ -61,6 +62,7 @@ class Service(fileName: String = "app.yml") : Closeable {
init {
val consumerSettings = settings.kafkaConsumerSettings
consumerSettings.setProperty("max.poll.records", CONSUMER_MAX_POLL_RECORDS)
consumerSettings.setProperty("max.poll.interval.ms", CONSUMER_MAX_INTERVAL_MS)
consumer = Consumer(consumerSettings, settings.inputTopic)
producer = Producer(settings.kafkaProducerSettings, settings.outputTopic)
log.info("Connected to Kafka.")
......
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