alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-479 Forced fsync slows down tests

Browse Source
This commit is contained in:
Jiri Pechanec 2017-11-22 11:28:44 +01:00 committed by Gunnar Morling
parent 833e81a3a4
commit 57e7f84163
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
View File

@ -93,7 +93,7 @@ protected String zookeeperConnection() {
*/
protected void populateDefaultConfiguration(Properties props) {
config.setProperty(KafkaConfig.NumPartitionsProp(), String.valueOf(1));
config.setProperty(KafkaConfig.LogFlushIntervalMessagesProp(), String.valueOf(1));
config.setProperty(KafkaConfig.LogFlushIntervalMessagesProp(), String.valueOf(Long.MAX_VALUE));
}
/**