You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2012/11/09 23:58:28 UTC
svn commit: r1407680 [3/4] - in /incubator/kafka/branches/0.8/system_test:
./ migration_tool_testsuite/ migration_tool_testsuite/testcase_9001/
migration_tool_testsuite/testcase_9003/
migration_tool_testsuite/testcase_9004/ migration_tool_testsuite/tes...
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4001/testcase_4001_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4001/testcase_4001_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4001/testcase_4001_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4001/testcase_4001_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : Base Test",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:-1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/testcase_4002_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/testcase_4002_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/testcase_4002_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4002/testcase_4002_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. acks => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/testcase_4003_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/testcase_4003_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/testcase_4003_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4003/testcase_4003_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. acks => -1, comp => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:-1, comp:1",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/testcase_4004_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/testcase_4004_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/testcase_4004_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4004/testcase_4004_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. acks => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:1, comp:1",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/testcase_4005_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/testcase_4005_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/testcase_4005_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4005/testcase_4005_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. sync => false, acks => -1, comp => 0",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:async, acks:-1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"false",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"false",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/testcase_4006_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/testcase_4006_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/testcase_4006_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4006/testcase_4006_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. acks => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:async, acks:1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"false",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"false",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. acks => -1, 2. comp => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:async, acks:-1, comp:1",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"false",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"false",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/testcase_4008_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/testcase_4008_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/testcase_4008_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4008/testcase_4008_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention : 1. acks => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 3 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:async, acks:1, comp:1",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "3",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"false",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"false",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/testcase_4011_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/testcase_4011_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/testcase_4011_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4011/testcase_4011_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention (Replica Factor < No. of Brokers) : Base Test",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 2 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:-1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "2",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/testcase_4012_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/testcase_4012_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/testcase_4012_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4012/testcase_4012_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention (Replica Factor < No. of Brokers) : 1. acks => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 2 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "2",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/testcase_4013_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/testcase_4013_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/testcase_4013_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4013/testcase_4013_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention (Replica Factor < No. of Brokers) : 1. acks => -1, comp => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 2 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:-1, comp:1",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "2",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/testcase_4014_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/testcase_4014_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/testcase_4014_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4014/testcase_4014_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention (Replica Factor < No. of Brokers) : 1. acks => 1",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 2 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:sync, acks:1, comp:1",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "2",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "1",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "1",
+ "sync":"true",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/cluster_config.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/cluster_config.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/cluster_config.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/cluster_config.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,76 @@
+{
+ "cluster_config": [
+ {
+ "entity_id": "0",
+ "hostname": "localhost",
+ "role": "zookeeper",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9990"
+ },
+ {
+ "entity_id": "1",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9991"
+ },
+ {
+ "entity_id": "2",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9992"
+ },
+ {
+ "entity_id": "3",
+ "hostname": "localhost",
+ "role": "broker",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9993"
+ },
+ {
+ "entity_id": "4",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9997"
+ },
+ {
+ "entity_id": "5",
+ "hostname": "localhost",
+ "role": "producer_performance",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9998"
+ },
+ {
+ "entity_id": "6",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9999"
+ },
+ {
+ "entity_id": "7",
+ "hostname": "localhost",
+ "role": "console_consumer",
+ "cluster_name": "source",
+ "kafka_home": "default",
+ "java_home": "default",
+ "jmx_port": "9191"
+ }
+ ]
+}
Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/testcase_4015_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/testcase_4015_properties.json?rev=1407680&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/testcase_4015_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_4015/testcase_4015_properties.json Fri Nov 9 22:58:23 2012
@@ -0,0 +1,103 @@
+{
+ "description": {"01":"Broker Log Retention (Replica Factor < No. of Brokers) : 1. sync => false, acks => -1, comp => 0",
+ "02":"Produce and consume messages to 2 topics - 2 partitions",
+ "03":"This test sends messages to 2 replicas",
+ "04":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)",
+ "05":"Restart the terminated broker",
+ "06":"Lookup brokers' log4j messages and verify that leader is re-elected successfully",
+ "07":"At the end it verifies the log size and contents",
+ "08":"Use a consumer to verify no message loss.",
+ "09":"Producer dimensions : mode:async, acks:-1, comp:0",
+ "10":"Log segment size : 102400"
+ },
+ "testcase_args": {
+ "broker_type": "leader",
+ "bounce_broker": "true",
+ "replica_factor": "2",
+ "num_partition": "2",
+ "num_iteration": "1",
+ "sleep_seconds_between_producer_calls": "1",
+ "broker_down_time_in_sec": "5",
+ "message_producing_free_time_sec": "15",
+ "log_retention_test": "true"
+ },
+ "entities": [
+ {
+ "entity_id": "0",
+ "clientPort": "2188",
+ "dataDir": "/tmp/zookeeper_0",
+ "log_filename": "zookeeper_2188.log",
+ "config_filename": "zookeeper_2188.properties"
+ },
+ {
+ "entity_id": "1",
+ "port": "9091",
+ "brokerid": "1",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_1_logs",
+ "log_filename": "kafka_server_9091.log",
+ "config_filename": "kafka_server_9091.properties"
+ },
+ {
+ "entity_id": "2",
+ "port": "9092",
+ "brokerid": "2",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_2_logs",
+ "log_filename": "kafka_server_9092.log",
+ "config_filename": "kafka_server_9092.properties"
+ },
+ {
+ "entity_id": "3",
+ "port": "9093",
+ "brokerid": "3",
+ "log.file.size": "102400",
+ "log.retention.size": "1048576",
+ "log.dir": "/tmp/kafka_server_3_logs",
+ "log_filename": "kafka_server_9093.log",
+ "config_filename": "kafka_server_9093.properties"
+ },
+ {
+ "entity_id": "4",
+ "topic": "test_1",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"false",
+ "log_filename": "producer_performance_4.log",
+ "config_filename": "producer_performance_4.properties"
+ },
+ {
+ "entity_id": "5",
+ "topic": "test_2",
+ "threads": "5",
+ "compression-codec": "0",
+ "message-size": "500",
+ "message": "500",
+ "request-num-acks": "-1",
+ "sync":"false",
+ "log_filename": "producer_performance_5.log",
+ "config_filename": "producer_performance_5.properties"
+ },
+ {
+ "entity_id": "6",
+ "topic": "test_1",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_6.log",
+ "config_filename": "console_consumer_6.properties"
+ },
+ {
+ "entity_id": "7",
+ "topic": "test_2",
+ "groupid": "mytestgroup",
+ "consumer-timeout-ms": "60000",
+ "log_filename": "console_consumer_7.log",
+ "config_filename": "console_consumer_7.properties"
+ }
+ ]
+}