kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1404197 - in /incubator/kafka/branches/0.8/system_test: mirror_maker_testsuite/testcase_5001/ mirror_maker_testsuite/testcase_5002/ replication_testsuite/testcase_0001/ replication_testsuite/testcase_0002/ replication_testsuite/testcase_00...
Date Wed, 31 Oct 2012 15:21:13 GMT
Author: junrao
Date: Wed Oct 31 15:21:11 2012
New Revision: 1404197

URL: http://svn.apache.org/viewvc?rev=1404197&view=rev
Log:
Update System Test due to new argument --sync in ProducerPerformance; patched by Jun Rao; reviewed by Neha Narkhede and Jun Rao; kafka-594

Modified:
    incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json
    incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json
    incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json
    incubator/kafka/branches/0.8/system_test/utils/kafka_system_test_utils.py

Modified: incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json Wed Oct 31 15:21:11 2012
@@ -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"
     },

Modified: incubator/kafka/branches/0.8/system_test/utils/kafka_system_test_utils.py
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/utils/kafka_system_test_utils.py?rev=1404197&r1=1404196&r2=1404197&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/utils/kafka_system_test_utils.py (original)
+++ incubator/kafka/branches/0.8/system_test/utils/kafka_system_test_utils.py Wed Oct 31 15:21:11 2012
@@ -821,7 +821,16 @@ def start_producer_in_thread(testcaseEnv
     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":
@@ -843,8 +852,8 @@ def start_producer_in_thread(testcaseEnv
     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 @@ def start_producer_in_thread(testcaseEnv
                        "--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,



Mime
View raw message