Index: system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json =================================================================== --- system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json (revision 1403739) +++ system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json (working copy) @@ -113,7 +113,7 @@ "message-size": "500", "message": "500", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_10.log", "config_filename": "producer_performance_10.properties" }, Index: system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json =================================================================== --- system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json (revision 1403739) +++ system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json (working copy) @@ -113,7 +113,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_10.log", "config_filename": "producer_performance_10.properties" }, Index: system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json (working copy) @@ -29,7 +29,7 @@ "entity_id": "1", "port": "9091", "brokerid": "1", - "log.file.size": "1024000000", + "log.file.size": "10240", "log.dir": "/tmp/kafka_server_1_logs", "log_filename": "kafka_server_9091.log", "config_filename": "kafka_server_9091.properties" @@ -38,7 +38,7 @@ "entity_id": "2", "port": "9092", "brokerid": "2", - "log.file.size": "1024000000", + "log.file.size": "10240", "log.dir": "/tmp/kafka_server_2_logs", "log_filename": "kafka_server_9092.log", "config_filename": "kafka_server_9092.properties" @@ -47,7 +47,7 @@ "entity_id": "3", "port": "9093", "brokerid": "3", - "log.file.size": "1024000000", + "log.file.size": "10240", "log.dir": "/tmp/kafka_server_3_logs", "log_filename": "kafka_server_9093.log", "config_filename": "kafka_server_9093.properties" @@ -58,9 +58,9 @@ "threads": "5", "compression-codec": "0", "message-size": "500", - "message": "100000", + "message": "500", "request-num-acks": "-1", - "sync":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json (working copy) @@ -60,7 +60,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json (working copy) @@ -59,7 +59,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_4.log", "config_filename": "producer_performance_4.properties" }, @@ -71,7 +71,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_5.log", "config_filename": "producer_performance_5.properties" }, Index: system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json (working copy) @@ -59,7 +59,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_4.log", "config_filename": "producer_performance_4.properties" }, @@ -71,7 +71,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_5.log", "config_filename": "producer_performance_5.properties" }, Index: system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json (working copy) @@ -59,7 +59,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance_4.log", "config_filename": "producer_performance_4.properties" }, @@ -71,7 +71,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance_5.log", "config_filename": "producer_performance_5.properties" }, Index: system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json (working copy) @@ -63,7 +63,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_4.log", "config_filename": "producer_performance_4.properties" }, @@ -74,7 +74,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_5.log", "config_filename": "producer_performance_5.properties" }, Index: system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_4.log", "config_filename": "producer_performance_4.properties" }, @@ -74,7 +74,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance_5.log", "config_filename": "producer_performance_5.properties" }, Index: system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance_4.log", "config_filename": "producer_performance_4.properties" }, @@ -74,7 +74,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance_5.log", "config_filename": "producer_performance_5.properties" }, Index: system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json (working copy) @@ -64,7 +64,8 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", + "producer-retry-backoff-ms": "2500", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json (working copy) @@ -64,7 +64,8 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", + "producer-retry-backoff-ms": "2500", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json (working copy) @@ -64,7 +64,8 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", + "producer-retry-backoff-ms": "2500", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json (working copy) @@ -64,7 +64,8 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", + "producer-retry-backoff-ms": "2500", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json (working copy) @@ -64,7 +64,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "-1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"false", + "sync":"true", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json =================================================================== --- system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json (revision 1403739) +++ system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json (working copy) @@ -62,7 +62,7 @@ "message-size": "500", "message": "100", "request-num-acks": "1", - "async":"true", + "sync":"false", "log_filename": "producer_performance.log", "config_filename": "producer_performance.properties" }, Index: system_test/utils/kafka_system_test_utils.py =================================================================== --- system_test/utils/kafka_system_test_utils.py (revision 1403739) +++ system_test/utils/kafka_system_test_utils.py (working copy) @@ -821,8 +821,17 @@ messageSize = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "message-size") noMsgPerBatch = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "message") requestNumAcks = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "request-num-acks") - asyncMode = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "async") + syncMode = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "sync") + retryBackoffMs = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "producer-retry-backoff-ms") + numOfRetries = system_test_utils.get_data_by_lookup_keyval(testcaseConfigsList, "entity_id", entityId, "producer-num-retries") + # for optional properties in testcase_xxxx_properties.json, + # check the length of returned value for those properties: + if len(retryBackoffMs) == 0: # no setting for "producer-retry-backoff-ms" + retryBackoffMs = "100" # default + if len(numOfRetries) == 0: # no setting for "producer-num-retries" + numOfRetries = "3" # default + brokerListStr = "" if clusterName == "source": brokerListStr = testcaseEnv.userDefinedEnvVarDict["sourceBrokerList"] @@ -843,8 +852,8 @@ producerSleepSec = int(testcaseEnv.testcaseArgumentsDict["sleep_seconds_between_producer_calls"]) boolArgumentsStr = "" - if asyncMode.lower() == "true": - boolArgumentsStr = boolArgumentsStr + " --async" + if syncMode.lower() == "true": + boolArgumentsStr = boolArgumentsStr + " --sync" # keep calling producer until signaled to stop by: # testcaseEnv.userDefinedEnvVarDict["stopBackgroundProducer"] @@ -869,6 +878,8 @@ "--compression-codec " + compCodec, "--message-size " + messageSize, "--request-num-acks " + requestNumAcks, + "--producer-retry-backoff-ms " + retryBackoffMs, + "--producer-num-retries " + numOfRetries, "--csv-reporter-enabled", "--metrics-dir " + get_testcase_config_log_dir_pathname(testcaseEnv, "producer_performance", entityId, "metrics"), boolArgumentsStr,