Skip to content

Commit

Permalink
Tell kafka broker to wait up to 10 seconds before answering
Browse files Browse the repository at this point in the history
if no data is available

* If data is available the request will be answered immediately because
  fetch.min.bytes defaults to 1. See: https://docs.confluent.io/platform/current/installation/configuration/consumer-configs.html#fetch-max-wait-ms

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
  • Loading branch information
Yannic92 committed Oct 29, 2021
1 parent 8e3e87b commit 8dcdb46
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions connectivity/service/src/main/resources/connectivity.conf
Original file line number Diff line number Diff line change
Expand Up @@ -390,6 +390,8 @@ ditto {
# can be defined in this configuration section.
kafka-clients {
enable.auto.commit = true
fetch.max.wait.ms = 10000
fetch.max.wait.ms = ${?KAFKA_CONSUMER_FETCH_MAX_WAIT_MS}
}
}
}
Expand Down

0 comments on commit 8dcdb46

Please sign in to comment.