kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1401875 [2/4] - in /incubator/kafka/branches/0.8/system_test: ./ migration_tool_testsuite/ migration_tool_testsuite/0.7/ migration_tool_testsuite/0.7/bin/ migration_tool_testsuite/0.7/lib/ migration_tool_testsuite/config/ migration_tool_te...
Date Wed, 24 Oct 2012 20:56:21 GMT
Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer.properties?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer.properties (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer.properties Wed Oct 24 20:56:16 2012
@@ -1,80 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-# see kafka.producer.ProducerConfig for more details
-
-############################# Producer Basics #############################
-
-# need to set either broker.list or zk.connect
-
-# configure brokers statically
-# format: brokerid1:host1:port1,brokerid2:host2:port2 ...
-#broker.list=0:localhost:9092
-
-# discover brokers from ZK
-zk.connect=localhost:2181
-
-# zookeeper session timeout; default is 6000
-#zk.sessiontimeout.ms=
-
-# the max time that the client waits to establish a connection to zookeeper; default is 6000
-#zk.connectiontimeout.ms
-
-# name of the partitioner class for partitioning events; default partition spreads data randomly
-#partitioner.class=
-
-# specifies whether the messages are sent asynchronously (async) or synchronously (sync)
-producer.type=sync
-
-# specify the compression codec for all data generated: 0: no compression, 1: gzip
-compression.codec=0
-
-# message encoder
-serializer.class=kafka.serializer.StringEncoder
-
-# allow topic level compression
-#compressed.topics=
-
-# max message size; messages larger than that size are discarded; default is 1000000
-#max.message.size=
-
-
-############################# Async Producer #############################
-# maximum time, in milliseconds, for buffering data on the producer queue 
-#queue.time=
-
-# the maximum size of the blocking queue for buffering on the producer 
-#queue.size=
-
-# Timeout for event enqueue:
-# 0: events will be enqueued immediately or dropped if the queue is full
-# -ve: enqueue will block indefinitely if the queue is full
-# +ve: enqueue will block up to this many milliseconds if the queue is full
-#queue.enqueueTimeout.ms=
-
-# the number of messages batched at the producer 
-#batch.size=
-
-# the callback handler for one or multiple events 
-#callback.handler=
-
-# properties required to initialize the callback handler 
-#callback.handler.props=
-
-# the handler for events 
-#event.handler=
-
-# properties required to initialize the event handler 
-#event.handler.props=
-

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer_performance.properties
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer_performance.properties?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer_performance.properties (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/config/producer_performance.properties Wed Oct 24 20:56:16 2012
@@ -1,5 +0,0 @@
-topic=mytest
-message-size=100
-thread=5
-compression-codec=0
-request-num-acks=-1

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py Wed Oct 24 20:56:16 2012
@@ -185,52 +185,110 @@ class ReplicaBasicTest(ReplicationUtils,
                 # by "num_iterations" in testcase_n_properties.json
                 # =============================================
                 i = 1
-                numIterations = int(self.testcaseEnv.testcaseArgumentsDict["num_iteration"])
+                numIterations    = int(self.testcaseEnv.testcaseArgumentsDict["num_iteration"])
+                brokerType       = self.testcaseEnv.testcaseArgumentsDict["broker_type"]
+                bounceBrokerFlag = self.testcaseEnv.testcaseArgumentsDict["bounce_broker"]
                 while i <= numIterations:
-
                     self.log_message("Iteration " + str(i) + " of " + str(numIterations))
 
-                    self.log_message("looking up leader")
-                    leaderDict = kafka_system_test_utils.get_leader_elected_log_line(
-                        self.systemTestEnv, self.testcaseEnv, self.leaderAttributesDict)
+                    if brokerType == "leader" or brokerType == "follower":
+                        self.log_message("looking up leader")
+                        leaderDict = kafka_system_test_utils.get_leader_elected_log_line(
+                            self.systemTestEnv, self.testcaseEnv, self.leaderAttributesDict)
+            
+                        # ==========================
+                        # leaderDict looks like this:
+                        # ==========================
+                        #{'entity_id': u'3',
+                        # 'partition': '0',
+                        # 'timestamp': 1345050255.8280001,
+                        # 'hostname': u'localhost',
+                        # 'topic': 'test_1',
+                        # 'brokerid': '3'}
+           
+                        if brokerType == "leader":
+                            # validate to see if leader election is successful
+                            self.log_message("validating leader election")
+                            result = kafka_system_test_utils.validate_leader_election_successful( \
+                                         self.testcaseEnv, leaderDict, self.testcaseEnv.validationStatusDict)
+                
+                            # trigger leader re-election by stopping leader to get re-election latency
+                            self.log_message("bounce_broker flag : " + bounceBrokerFlag)
+                            if bounceBrokerFlag.lower() == "true":
+                                reelectionLatency = kafka_system_test_utils.get_reelection_latency(
+                                    self.systemTestEnv, self.testcaseEnv, leaderDict, self.leaderAttributesDict)
+                                latencyKeyName = "Leader Election Latency - iter " + str(i) + " brokerid " + leaderDict["brokerid"]
+                                self.testcaseEnv.validationStatusDict[latencyKeyName] = str("{0:.2f}".format(reelectionLatency * 1000)) + " ms"
+                                self.testcaseEnv.userDefinedEnvVarDict["leaderElectionLatencyList"].append("{0:.2f}".format(reelectionLatency * 1000))
+
+                                time.sleep(1)
+
+                                # starting previously terminated broker 
+                                self.log_message("starting the previously terminated broker")
+                                stoppedLeaderEntityId  = leaderDict["entity_id"]
+                                kafka_system_test_utils.start_entity_in_background(self.systemTestEnv, self.testcaseEnv, stoppedLeaderEntityId)
+                            else:
+                                try:
+                                    # GC Pause simulation
+                                    hostname  = leaderDict["hostname"]
+                                    pauseTime = self.testcaseEnv.testcaseArgumentsDict["pause_time_in_seconds"]
+                                    parentPid = self.testcaseEnv.entityBrokerParentPidDict[leaderDict["entity_id"]]
+                                    pidStack  = system_test_utils.get_remote_child_processes(hostname, parentPid)
+                                    system_test_utils.simulate_garbage_collection_pause_in_remote_process(hostname, pidStack, pauseTime)
+                                except:
+                                    pass
+
+                        else: # follower
+                            # a list of all brokers
+                            brokerEntityIdList = system_test_utils.get_data_from_list_of_dicts(
+                                self.systemTestEnv.clusterEntityConfigDictList, "role", "broker", "entity_id")
         
-                    # ==========================
-                    # leaderDict looks like this:
-                    # ==========================
-                    #{'entity_id': u'3',
-                    # 'partition': '0',
-                    # 'timestamp': 1345050255.8280001,
-                    # 'hostname': u'localhost',
-                    # 'topic': 'test_1',
-                    # 'brokerid': '3'}
+                            # we pick the follower from the first broker which is not the leader
+                            firstFollowerEntityId = None
+                            for brokerEntityId in brokerEntityIdList:
+                                if brokerEntityId != leaderDict["entity_id"]:
+                                    firstFollowerEntityId = brokerEntityId
+                                    break
+        
+                            # stopping Follower
+                            self.log_message("bounce_broker flag : " + bounceBrokerFlag)
+                            if bounceBrokerFlag.lower() == "true":
+                                self.log_message("stopping follower with entity id: " + firstFollowerEntityId)
+                                kafka_system_test_utils.stop_remote_entity(self.systemTestEnv, firstFollowerEntityId,
+                                    self.testcaseEnv.entityBrokerParentPidDict[firstFollowerEntityId])
+
+                                time.sleep(1)
+
+                                # starting previously terminated broker 
+                                self.log_message("starting the previously terminated broker")
+                                stoppedBrokerEntityId  = firstFollowerEntityId
+                                kafka_system_test_utils.start_entity_in_background(self.systemTestEnv, self.testcaseEnv, stoppedBrokerEntityId)
+    
+                    elif brokerType == "controller":
+                        self.log_message("looking up controller")
+                        controllerDict = kafka_system_test_utils.get_controller_attributes(self.systemTestEnv, self.testcaseEnv)
         
-                    # =============================================
-                    # validate to see if leader election is successful
-                    # =============================================
-                    self.log_message("validating leader election")
-                    result = kafka_system_test_utils.validate_leader_election_successful( \
-                                 self.testcaseEnv, leaderDict, self.testcaseEnv.validationStatusDict)
+                        # ==========================
+                        # controllerDict looks like this:
+                        # ==========================
+                        #{'entity_id': u'3',
+                        # 'timestamp': 1345050255.8280001,
+                        # 'hostname': u'localhost',
+                        # 'brokerid': '3'}
         
-                    # =============================================
-                    # trigger leader re-election by stopping leader
-                    # to get re-election latency
-                    # =============================================
-                    bounceLeaderFlag = self.testcaseEnv.testcaseArgumentsDict["bounce_leader"]
-                    self.log_message("bounce_leader flag : " + bounceLeaderFlag)
-                    if (bounceLeaderFlag.lower() == "true"):
-                        reelectionLatency = kafka_system_test_utils.get_reelection_latency(
-                            self.systemTestEnv, self.testcaseEnv, leaderDict, self.leaderAttributesDict)
-                        latencyKeyName = "Leader Election Latency - iter " + str(i) + " brokerid " + leaderDict["brokerid"]
-                        self.testcaseEnv.validationStatusDict[latencyKeyName] = str("{0:.2f}".format(reelectionLatency * 1000)) + " ms"
-                        self.testcaseEnv.userDefinedEnvVarDict["leaderElectionLatencyList"].append("{0:.2f}".format(reelectionLatency * 1000))
-
-                    # =============================================
-                    # starting previously terminated broker 
-                    # =============================================
-                    if bounceLeaderFlag.lower() == "true":
-                        self.log_message("starting the previously terminated broker")
-                        stoppedLeaderEntityId  = leaderDict["entity_id"]
-                        kafka_system_test_utils.start_entity_in_background(self.systemTestEnv, self.testcaseEnv, stoppedLeaderEntityId)
+                        # stopping Controller
+                        self.log_message("bounce_broker flag : " + bounceBrokerFlag)
+                        if bounceBrokerFlag.lower() == "true":
+                            self.log_message("stopping controller : " + controllerDict["brokerid"])
+                            kafka_system_test_utils.stop_remote_entity(self.systemTestEnv, controllerDict["entity_id"], 
+                                self.testcaseEnv.entityBrokerParentPidDict[controllerDict["entity_id"]])
+
+                            time.sleep(1)
+
+                            # starting previously terminated broker 
+                            self.log_message("starting the previously terminated broker")
+                            stoppedBrokerEntityId  = controllerDict["entity_id"]
+                            kafka_system_test_utils.start_entity_in_background(self.systemTestEnv, self.testcaseEnv, stoppedBrokerEntityId)
 
                     self.anonLogger.info("sleeping for 15s")
                     time.sleep(15)
@@ -279,8 +337,9 @@ class ReplicaBasicTest(ReplicationUtils,
                 # =============================================
                 # starting consumer
                 # =============================================
-                self.log_message("starting consumer in the background")
-                kafka_system_test_utils.start_console_consumer(self.systemTestEnv, self.testcaseEnv)
+                self.log_message("starting debug consumers in the background")
+                #kafka_system_test_utils.start_console_consumer(self.systemTestEnv, self.testcaseEnv)
+                kafka_system_test_utils.start_simple_consumer(self.systemTestEnv, self.testcaseEnv)
                 self.anonLogger.info("sleeping for 10s")
                 time.sleep(10)
                     
@@ -306,7 +365,8 @@ class ReplicaBasicTest(ReplicationUtils,
                 # validate the data matched and checksum
                 # =============================================
                 self.log_message("validating data matched")
-                kafka_system_test_utils.validate_data_matched(self.systemTestEnv, self.testcaseEnv)
+                #kafka_system_test_utils.validate_data_matched(self.systemTestEnv, self.testcaseEnv)
+                kafka_system_test_utils.validate_simple_consumer_data_matched(self.systemTestEnv, self.testcaseEnv)
                 kafka_system_test_utils.validate_broker_log_segment_checksum(self.systemTestEnv, self.testcaseEnv)
 
                 # =============================================

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 1048576 (1M)"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 512000"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json Wed Oct 24 20:56:16 2012
@@ -8,7 +8,8 @@
                   "07":"Log segment size    : 512000"
   },
   "testcase_args": {
-    "bounce_leader": "false",
+    "broker_type": "leader",
+    "bounce_broker": "false",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "1",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 10240"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 1048576 (1M)"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "1",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 102400"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 512000"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Modified: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json?rev=1401875&r1=1401874&r2=1401875&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json (original)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json Wed Oct 24 20:56:16 2012
@@ -11,7 +11,8 @@
                   "10":"Log segment size    : 512000"
   },
   "testcase_args": {
-    "bounce_leader": "true",
+    "broker_type": "leader",
+    "bounce_broker": "true",
     "replica_factor": "3",
     "num_partition": "3",
     "num_iteration": "3",

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "-1",
+      "async":"false",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "-1",
+      "async":"true",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "1",
+      "async":"false",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "1",
+      "async":"true",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "-1",
+      "async":"false",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "-1",
+      "async":"true",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "1",
+      "async":"false",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "description": {"01":"Multi Leader Failures (SIGKILL) in Replication : 1. mode => async; 2. acks => 1; 3. 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",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "1",
+      "async":"true",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "description": {"01":"Multi Controller Failures (SIGTERM) 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": "controller",
+    "bounce_broker": "true",
+    "signal_type": "SIGTERM",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "-1",
+      "async":"false",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "description": {"01":"Multi Controller Failures (SIGTERM) 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": "controller",
+    "bounce_broker": "true",
+    "signal_type": "SIGTERM",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "-1",
+      "async":"true",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "description": {"01":"Multi Controller Failures (SIGTERM) 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": "controller",
+    "bounce_broker": "true",
+    "signal_type": "SIGTERM",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "1",
+      "async":"false",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}

Added: incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json?rev=1401875&view=auto
==============================================================================
--- incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json (added)
+++ incubator/kafka/branches/0.8/system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json Wed Oct 24 20:56:16 2012
@@ -0,0 +1,81 @@
+{
+  "description": {"01":"Multi Controller Failures (SIGTERM) 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": "controller",
+    "bounce_broker": "true",
+    "signal_type": "SIGTERM",
+    "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",
+      "brokerid": "1",
+      "log.file.size": "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",
+      "brokerid": "2",
+      "log.file.size": "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",
+      "brokerid": "3",
+      "log.file.size": "102400",
+      "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": "100",
+      "request-num-acks": "1",
+      "async":"true",
+      "log_filename": "producer_performance.log",
+      "config_filename": "producer_performance.properties"
+    },
+    {
+      "entity_id": "5",
+      "topic": "test_1",
+      "groupid": "mytestgroup",
+      "consumer-timeout-ms": "10000",
+      "zookeeper": "localhost:2188",
+      "log_filename": "console_consumer.log",
+      "config_filename": "console_consumer.properties"
+    }
+  ]
+}



Mime
View raw message