Changeset View
Changeset View
Standalone View
Standalone View
data/common/kafka.yaml
Show All 18 Lines | kafka::logdirs: | ||||
- /srv/kafka/logdir | - /srv/kafka/logdir | ||||
kafka::broker_config: | kafka::broker_config: | ||||
log.dirs: "%{alias('kafka::logdirs')}" | log.dirs: "%{alias('kafka::logdirs')}" | ||||
num.recovery.threads.per.data.dir: 10 | num.recovery.threads.per.data.dir: 10 | ||||
# Increase zookeeper and replication timeouts | # Increase zookeeper and replication timeouts | ||||
# https://cwiki.apache.org/confluence/display/KAFKA/KIP-537%3A+Increase+default+zookeeper+session+timeout will be default in 2.5.0 | # https://cwiki.apache.org/confluence/display/KAFKA/KIP-537%3A+Increase+default+zookeeper+session+timeout will be default in 2.5.0 | ||||
zookeeper.session.timeout.ms: 18000 | zookeeper.session.timeout.ms: 18000 | ||||
replica.lag.time.max.ms: 30000 | replica.lag.time.max.ms: 30000 | ||||
# Bump consumer offset retention to 30 days instead of the default of 7 days | |||||
offsets.retention.minutes: 43200 | |||||
# Increase the socket request max size to 200 MB | # Increase the socket request max size to 200 MB | ||||
socket.request.max.bytes: 209715200 | socket.request.max.bytes: 209715200 | ||||
# And the max message size to 100 MB | # And the max message size to 100 MB | ||||
message.max.bytes: 104857600 | message.max.bytes: 104857600 | ||||
# For upgrades after 2.6 | # For upgrades after 2.6 | ||||
inter.broker.protocol.version: "2.6" | inter.broker.protocol.version: "2.6" | ||||
# kafka::broker::password in private-data | # kafka::broker::password in private-data | ||||
Show All 35 Lines |