http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json b/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json deleted file mode 100644 index fe5e49a..0000000 --- a/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json +++ /dev/null @@ -1,109 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. mode => async; 2. comp => 0", - "02":"Produce and consume messages to 2 topics - 3 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 : 512000" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"false", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"false", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -}
http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0124/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0124/cluster_config.json b/system_test/replication_testsuite/testcase_0124/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0124/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0124/testcase_0124_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0124/testcase_0124_properties.json b/system_test/replication_testsuite/testcase_0124/testcase_0124_properties.json deleted file mode 100644 index bff5d73..0000000 --- a/system_test/replication_testsuite/testcase_0124/testcase_0124_properties.json +++ /dev/null @@ -1,113 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. log.index.interval.bytes => 490", - "02":"Setting log.index.interval.bytes to slightly smaller than message size to force indexing on each message", - "03":"Produce and consume messages to 2 topics - 3 partitions", - "04":"This test sends messages to 3 replicas", - "05":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)", - "06":"Restart the terminated broker", - "07":"Lookup brokers' log4j messages and verify that leader is re-elected successfully", - "08":"At the end it verifies the log size and contents", - "09":"Use a consumer to verify no message loss.", - "10":"Producer dimensions : mode:sync, acks:-1, comp:0", - "11":"Log segment size : 102400" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0125/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0125/cluster_config.json b/system_test/replication_testsuite/testcase_0125/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0125/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0125/testcase_0125_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0125/testcase_0125_properties.json b/system_test/replication_testsuite/testcase_0125/testcase_0125_properties.json deleted file mode 100644 index 1f57ecc..0000000 --- a/system_test/replication_testsuite/testcase_0125/testcase_0125_properties.json +++ /dev/null @@ -1,113 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. ack => 1", - "02":"Setting log.index.interval.bytes to slightly smaller than message size to force indexing on each message", - "03":"Produce and consume messages to 2 topics - 3 partitions", - "04":"This test sends messages to 3 replicas", - "05":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)", - "06":"Restart the terminated broker", - "07":"Lookup brokers' log4j messages and verify that leader is re-elected successfully", - "08":"At the end it verifies the log size and contents", - "09":"Use a consumer to verify no message loss.", - "10":"Producer dimensions : mode:sync, acks:1, comp:0", - "11":"Log segment size : 102400" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0126/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0126/cluster_config.json b/system_test/replication_testsuite/testcase_0126/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0126/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0126/testcase_0126_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0126/testcase_0126_properties.json b/system_test/replication_testsuite/testcase_0126/testcase_0126_properties.json deleted file mode 100644 index ffa0fc3..0000000 --- a/system_test/replication_testsuite/testcase_0126/testcase_0126_properties.json +++ /dev/null @@ -1,113 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. ack => -1, 2. comp => 1", - "02":"Setting log.index.interval.bytes to slightly smaller than message size to force indexing on each message", - "03":"Produce and consume messages to 2 topics - 3 partitions", - "04":"This test sends messages to 3 replicas", - "05":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)", - "06":"Restart the terminated broker", - "07":"Lookup brokers' log4j messages and verify that leader is re-elected successfully", - "08":"At the end it verifies the log size and contents", - "09":"Use a consumer to verify no message loss.", - "10":"Producer dimensions : mode:sync, acks:-1, comp:1", - "11":"Log segment size : 102400" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0127/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0127/cluster_config.json b/system_test/replication_testsuite/testcase_0127/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0127/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0127/testcase_0127_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0127/testcase_0127_properties.json b/system_test/replication_testsuite/testcase_0127/testcase_0127_properties.json deleted file mode 100644 index 78ecd8f..0000000 --- a/system_test/replication_testsuite/testcase_0127/testcase_0127_properties.json +++ /dev/null @@ -1,113 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. ack => 1", - "02":"Setting log.index.interval.bytes to slightly smaller than message size to force indexing on each message", - "03":"Produce and consume messages to 2 topics - 3 partitions", - "04":"This test sends messages to 3 replicas", - "05":"To trigger leader election: find the leader and terminate by controlled failure (kill -15)", - "06":"Restart the terminated broker", - "07":"Lookup brokers' log4j messages and verify that leader is re-elected successfully", - "08":"At the end it verifies the log size and contents", - "09":"Use a consumer to verify no message loss.", - "10":"Producer dimensions : mode:sync, acks:1, comp:1", - "11":"Log segment size : 102400" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log.index.interval.bytes": "490", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0128/testcase_0128_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0128/testcase_0128_properties.json b/system_test/replication_testsuite/testcase_0128/testcase_0128_properties.json deleted file mode 100644 index 589eb20..0000000 --- a/system_test/replication_testsuite/testcase_0128/testcase_0128_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. auto_create_topic => true", - "02":"Produce and consume messages to 2 topics - 3 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": "3", - "num_iteration": "3", - "auto_create_topic": "true", - "producer_multi_topics_mode": "true", - "consumer_multi_topics_mode": "true", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "num.partitions": "3", - "default.replication.factor": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "num.partitions": "3", - "default.replication.factor": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "num.partitions": "3", - "default.replication.factor": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1,test_2", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "3500", - "producer-num-retries": "3", - "sync":"false", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "topic": "test_1,test_2", - "groupid": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_5.log", - "config_filename": "console_consumer_5.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0131/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0131/cluster_config.json b/system_test/replication_testsuite/testcase_0131/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0131/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0131/testcase_0131_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0131/testcase_0131_properties.json b/system_test/replication_testsuite/testcase_0131/testcase_0131_properties.json deleted file mode 100644 index 0324b6f..0000000 --- a/system_test/replication_testsuite/testcase_0131/testcase_0131_properties.json +++ /dev/null @@ -1,112 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : Base Test", - "02":"Produce and consume messages to 2 topics - 3 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", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "2", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log.index.interval.bytes": "10", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log.index.interval.bytes": "10", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log.index.interval.bytes": "10", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0132/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0132/cluster_config.json b/system_test/replication_testsuite/testcase_0132/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0132/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0132/testcase_0132_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0132/testcase_0132_properties.json b/system_test/replication_testsuite/testcase_0132/testcase_0132_properties.json deleted file mode 100644 index 83bcaaa..0000000 --- a/system_test/replication_testsuite/testcase_0132/testcase_0132_properties.json +++ /dev/null @@ -1,109 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. acks => 1", - "02":"Produce and consume messages to 2 topics - 3 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 : 512000" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "2", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"true", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0133/cluster_config.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0133/cluster_config.json b/system_test/replication_testsuite/testcase_0133/cluster_config.json deleted file mode 100644 index cf147eb..0000000 --- a/system_test/replication_testsuite/testcase_0133/cluster_config.json +++ /dev/null @@ -1,76 +0,0 @@ -{ - "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": "9099" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0133/testcase_0133_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0133/testcase_0133_properties.json b/system_test/replication_testsuite/testcase_0133/testcase_0133_properties.json deleted file mode 100644 index 2a1eaa5..0000000 --- a/system_test/replication_testsuite/testcase_0133/testcase_0133_properties.json +++ /dev/null @@ -1,109 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. mode => async; 2. comp => 0", - "02":"Produce and consume messages to 2 topics - 3 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:1", - "10":"Log segment size : 512000" - }, - "testcase_args": { - "broker_type": "leader", - "auto_create_topic": "true", - "bounce_broker": "true", - "replica_factor": "2", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "512000", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "2", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"false", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "new-producer":"true", - "topic": "test_2", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "producer-retry-backoff-ms": "300", - "sync":"false", - "log_filename": "producer_performance_5.log", - "config_filename": "producer_performance_5.properties" - }, - { - "entity_id": "6", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_6.log", - "config_filename": "console_consumer_6.properties" - }, - { - "entity_id": "7", - "topic": "test_2", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_7.log", - "config_filename": "console_consumer_7.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0134/testcase_0134_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0134/testcase_0134_properties.json b/system_test/replication_testsuite/testcase_0134/testcase_0134_properties.json deleted file mode 100644 index 0a98ce5..0000000 --- a/system_test/replication_testsuite/testcase_0134/testcase_0134_properties.json +++ /dev/null @@ -1,93 +0,0 @@ -{ - "description": {"01":"Leader Failure in Replication with multi topics & partitions : 1. auto_create_topic => true", - "02":"Produce and consume messages to 2 topics - 3 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": "3", - "num_iteration": "3", - "auto_create_topic": "true", - "producer_multi_topics_mode": "true", - "consumer_multi_topics_mode": "true", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15" - }, - "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", - "broker.id": "1", - "num.partitions": "3", - "default.replication.factor": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "log.index.interval.bytes": "10", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "num.partitions": "3", - "default.replication.factor": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "log.index.interval.bytes": "10", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "num.partitions": "3", - "default.replication.factor": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "log.index.interval.bytes": "10", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1,test_2", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "producer-retry-backoff-ms": "3500", - "producer-num-retries": "3", - "sync":"false", - "log_filename": "producer_performance_4.log", - "config_filename": "producer_performance_4.properties" - }, - { - "entity_id": "5", - "topic": "test_1,test_2", - "groupid": "mytestgroup", - "consumer-timeout-ms": "10000", - "log_filename": "console_consumer_5.log", - "config_filename": "console_consumer_5.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json b/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json deleted file mode 100644 index 237a343..0000000 --- a/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : Base Test", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "sync":"true", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json b/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json deleted file mode 100644 index 8d57610..0000000 --- a/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. mode => async", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "sync":"false", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json b/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json deleted file mode 100644 index 89b933f..0000000 --- a/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. acks => 1", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "sync":"true", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json b/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json deleted file mode 100644 index fe3f98f..0000000 --- a/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. mode => async; 2. acks => 1", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "0", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "sync":"false", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json b/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json deleted file mode 100644 index 7f9ced8..0000000 --- a/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. comp => 1", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "sync":"true", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json b/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json deleted file mode 100644 index ec1e83c..0000000 --- a/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. mode => async; 2. comp => 1", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "-1", - "sync":"false", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -} http://git-wip-us.apache.org/repos/asf/kafka/blob/d50499a0/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json ---------------------------------------------------------------------- diff --git a/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json b/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json deleted file mode 100644 index e96ed32..0000000 --- a/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json +++ /dev/null @@ -1,90 +0,0 @@ -{ - "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. acks => 1; 2. comp => 1", - "02":"Produce and consume messages to a single topic - three partition.", - "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", - "auto_create_topic": "true", - "bounce_broker": "true", - "signal_type": "SIGKILL", - "replica_factor": "3", - "num_partition": "3", - "num_iteration": "3", - "sleep_seconds_between_producer_calls": "1", - "message_producing_free_time_sec": "15", - "num_messages_to_produce_per_producer_call": "50" - }, - "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", - "broker.id": "1", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_1_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9091.log", - "config_filename": "kafka_server_9091.properties" - }, - { - "entity_id": "2", - "port": "9092", - "broker.id": "2", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_2_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9092.log", - "config_filename": "kafka_server_9092.properties" - }, - { - "entity_id": "3", - "port": "9093", - "broker.id": "3", - "log.segment.bytes": "102400", - "log.dir": "/tmp/kafka_server_3_logs", - "default.replication.factor": "3", - "num.partitions": "3", - "log_filename": "kafka_server_9093.log", - "config_filename": "kafka_server_9093.properties" - }, - { - "entity_id": "4", - "new-producer":"true", - "topic": "test_1", - "threads": "5", - "compression-codec": "1", - "message-size": "500", - "message": "100", - "request-num-acks": "1", - "sync":"true", - "producer-retry-backoff-ms": "3500", - "log_filename": "producer_performance.log", - "config_filename": "producer_performance.properties" - }, - { - "entity_id": "5", - "topic": "test_1", - "group.id": "mytestgroup", - "consumer-timeout-ms": "10000", - "zookeeper": "localhost:2188", - "log_filename": "console_consumer.log", - "config_filename": "console_consumer.properties" - } - ] -}
