openstack/deb-python-kafka
Code Issues Proposed changes

Reduce replica timeouts to 1sec for failover integration testing

Browse Source
This commit is contained in:
Dana Powers
2015-06-10 00:56:19 -07:00
parent 57b9c75df6
commit 4c9a3c6b9d
4 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
servers/0.8.0/resources/kafka.properties
View File

@@ -35,6 +35,10 @@ log.dirs={tmp_dir}/data
num.partitions={partitions} num.partitions={partitions}
default.replication.factor={replicas} default.replication.factor={replicas}
## Short Replica Lag -- Drops failed brokers out of ISR
replica.lag.time.max.ms=1000
replica.socket.timeout.ms=1000
############################# Log Flush Policy ############################# ############################# Log Flush Policy #############################
log.flush.interval.messages=10000 log.flush.interval.messages=10000

4
servers/0.8.1.1/resources/kafka.properties
View File

@@ -63,6 +63,10 @@ log.dirs={tmp_dir}/data
num.partitions={partitions} num.partitions={partitions}
default.replication.factor={replicas} default.replication.factor={replicas}
## Short Replica Lag -- Drops failed brokers out of ISR
replica.lag.time.max.ms=1000
replica.socket.timeout.ms=1000
############################# Log Flush Policy ############################# ############################# Log Flush Policy #############################
# Messages are immediately written to the filesystem but by default we only fsync() to sync # Messages are immediately written to the filesystem but by default we only fsync() to sync

4
servers/0.8.1/resources/kafka.properties
View File

@@ -35,6 +35,10 @@ log.dirs={tmp_dir}/data
num.partitions={partitions} num.partitions={partitions}
default.replication.factor={replicas} default.replication.factor={replicas}
## Short Replica Lag -- Drops failed brokers out of ISR
replica.lag.time.max.ms=1000
replica.socket.timeout.ms=1000
############################# Log Flush Policy ############################# ############################# Log Flush Policy #############################
log.flush.interval.messages=10000 log.flush.interval.messages=10000

4
servers/0.8.2.0/resources/kafka.properties
View File

@@ -63,6 +63,10 @@ log.dirs={tmp_dir}/data
num.partitions={partitions} num.partitions={partitions}
default.replication.factor={replicas} default.replication.factor={replicas}
## Short Replica Lag -- Drops failed brokers out of ISR
replica.lag.time.max.ms=1000
replica.socket.timeout.ms=1000
############################# Log Flush Policy ############################# ############################# Log Flush Policy #############################
# Messages are immediately written to the filesystem but by default we only fsync() to sync # Messages are immediately written to the filesystem but by default we only fsync() to sync