diff --git a/system_test/logging.conf b/system_test/logging.conf index e9e9213..afc024d 100644 --- a/system_test/logging.conf +++ b/system_test/logging.conf @@ -35,7 +35,7 @@ propagate=0 # ============================================== [handler_namedConsoleHandler] class=StreamHandler -level=INFO +level=DEBUG formatter=namedFormatter args=[] diff --git a/system_test/replication_testsuite/replica_basic_test.py b/system_test/replication_testsuite/replica_basic_test.py index 3fc47d9..bf6898e 100644 --- a/system_test/replication_testsuite/replica_basic_test.py +++ b/system_test/replication_testsuite/replica_basic_test.py @@ -397,7 +397,8 @@ class ReplicaBasicTest(ReplicationUtils, SetupUtils): if logRetentionTest.lower() == "false": self.log_message("starting consumer in the background") kafka_system_test_utils.start_console_consumer(self.systemTestEnv, self.testcaseEnv) - time.sleep(10) + self.anonLogger.info("sleeping for 60s") + time.sleep(60) # ============================================= # this testcase is completed - stop all entities diff --git a/system_test/replication_testsuite/testcase_0011/testcase_0011_properties.json b/system_test/replication_testsuite/testcase_0011/testcase_0011_properties.json new file mode 100644 index 0000000..32c66fd --- /dev/null +++ b/system_test/replication_testsuite/testcase_0011/testcase_0011_properties.json @@ -0,0 +1,86 @@ +{ + "description": {"01":"Replication Basic : 1. auto create topic => true", + "02":"Produce and consume messages to a single topic - 3 partitions.", + "03":"This test sends messages to 3 replicas", + "04":"At the end it verifies the log size and contents", + "05":"Use a consumer to verify no message loss.", + "06":"Producer dimensions : mode:async, acks:1, comp:1", + "07":"Log segment size : 1048576 (1M)" + }, + "testcase_args": { + "broker_type": "leader", + "bounce_broker": "false", + "replica_factor": "3", + "num_partition": "2", + "num_iteration": "1", + "auto_create_topic": "true", + "sleep_seconds_between_producer_calls": "1", + "message_producing_free_time_sec": "15", + "num_topics_for_auto_generated_string": "250", + "consumer_multi_topics_mode": "true", + "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", + "num.partitions": "3", + "default.replication.factor": "3", + "log.segment.size": "1048576", + "log.dir": "/tmp/kafka_server_1_logs", + "log_filename": "kafka_server_9091.log", + "config_filename": "kafka_server_9091.properties" + }, + { + "entity_id": "2", + "port": "9092", + "broker.id": "2", + "num.partitions": "3", + "default.replication.factor": "3", + "log.segment.size": "1048576", + "log.dir": "/tmp/kafka_server_2_logs", + "log_filename": "kafka_server_9092.log", + "config_filename": "kafka_server_9092.properties" + }, + { + "entity_id": "3", + "port": "9093", + "broker.id": "3", + "num.partitions": "3", + "default.replication.factor": "3", + "log.segment.size": "1048576", + "log.dir": "/tmp/kafka_server_3_logs", + "log_filename": "kafka_server_9093.log", + "config_filename": "kafka_server_9093.properties" + }, + { + "entity_id": "4", + "topic": "test_1", + "threads": "5", + "compression-codec": "1", + "message-size": "500", + "message": "100", + "request-num-acks": "1", + "sync":"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" + } + ] +} diff --git a/system_test/testcase_to_run.json b/system_test/testcase_to_run.json index 8252860..578e1a2 100644 --- a/system_test/testcase_to_run.json +++ b/system_test/testcase_to_run.json @@ -1,5 +1,5 @@ { "ReplicaBasicTest" : [ - "testcase_0001" + "testcase_0011" ] }