root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

KAFKA-10893 Increase target_messages_per_sec of ReplicaScaleTest to reduce the run time (#9797) 

Reviewers: David Arthur <mumrah@gmail.com>
This commit is contained in:
Chia-Ping Tsai 2021-01-05 00:23:34 +08:00 committed by GitHub
parent 8ac5ef90a0
commit ac7b5d3389
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/kafkatest/tests/core/replica_scale_test.py
View File

@ -72,7 +72,7 @@ class ReplicaScaleTest(Test):
produce_spec = ProduceBenchWorkloadSpec(0, TaskSpec.MAX_DURATION_MS, produce_spec = ProduceBenchWorkloadSpec(0, TaskSpec.MAX_DURATION_MS,
producer_workload_service.producer_node, producer_workload_service.producer_node,
producer_workload_service.bootstrap_servers, producer_workload_service.bootstrap_servers,
target_messages_per_sec=10000, target_messages_per_sec=150000,
max_messages=3400000, max_messages=3400000,
producer_conf={}, producer_conf={},
admin_client_conf={}, admin_client_conf={},
@ -83,12 +83,12 @@ class ReplicaScaleTest(Test):
}}) }})
produce_workload = trogdor.create_task("replicas-produce-workload", produce_spec) produce_workload = trogdor.create_task("replicas-produce-workload", produce_spec)
produce_workload.wait_for_done(timeout_sec=600) produce_workload.wait_for_done(timeout_sec=600)
self.logger.info("Completed produce bench") print("Completed produce bench", flush=True) # Force some stdout for Travis
consume_spec = ConsumeBenchWorkloadSpec(0, TaskSpec.MAX_DURATION_MS, consume_spec = ConsumeBenchWorkloadSpec(0, TaskSpec.MAX_DURATION_MS,
consumer_workload_service.consumer_node, consumer_workload_service.consumer_node,
consumer_workload_service.bootstrap_servers, consumer_workload_service.bootstrap_servers,
target_messages_per_sec=10000, target_messages_per_sec=150000,
max_messages=3400000, max_messages=3400000,
consumer_conf={}, consumer_conf={},
admin_client_conf={}, admin_client_conf={},