diff --git a/tests/rptest/perf/ts_read_openmessaging_test.py b/tests/rptest/perf/ts_read_openmessaging_test.py new file mode 100644 index 0000000000000..b6b8d58f7a70d --- /dev/null +++ b/tests/rptest/perf/ts_read_openmessaging_test.py @@ -0,0 +1,53 @@ +# Copyright 2023 Redpanda Data, Inc. +# +# Use of this software is governed by the Business Source License +# included in the file licenses/BSL.md +# +# As of the Change Date specified in that file, in accordance with +# the Business Source License, use of this software will be governed +# by the Apache License, Version 2.0 + +from rptest.tests.redpanda_test import RedpandaTest +from rptest.services.cluster import cluster +from rptest.services.openmessaging_benchmark import OpenMessagingBenchmark +from ducktape.mark import parametrize +from rptest.services.redpanda import SISettings + + +class TSReadOpenmessagingTest(RedpandaTest): + BENCHMARK_WAIT_TIME_MIN = 15 + + def __init__(self, ctx): + extra_rp_conf = { + "retention_local_target_bytes_default": 16 * 1_000_000 # 16 MB + } + si_settings = SISettings( + test_context=ctx, + log_segment_size=16 * 1_000_000, # 16 MB + cloud_storage_cache_chunk_size=8 * 1_000_000, # 8 MB + cloud_storage_spillover_manifest_max_segments=10, + ) + self._ctx = ctx + super(TSReadOpenmessagingTest, + self).__init__(test_context=ctx, + num_brokers=3, + si_settings=si_settings, + extra_rp_conf=extra_rp_conf) + + @cluster(num_nodes=6) + @parametrize(driver_idx="ACK_ALL_GROUP_LINGER_1MS_IDEM_MAX_IN_FLIGHT", + workload_idx="RELEASE_CERT_SMOKE_LOAD_625k_BACKLOG") + def test_perf(self, driver_idx, workload_idx): + """ + This adds TS reads to the OMB perf regression tests + """ + + assert self.redpanda.dedicated_nodes + + benchmark = OpenMessagingBenchmark(self._ctx, self.redpanda, + driver_idx, workload_idx) + benchmark.start() + benchmark_time_min = benchmark.benchmark_time( + ) + TSReadOpenmessagingTest.BENCHMARK_WAIT_TIME_MIN + benchmark.wait(timeout_sec=benchmark_time_min * 60) + benchmark.check_succeed() diff --git a/tests/rptest/services/openmessaging_benchmark_configs.py b/tests/rptest/services/openmessaging_benchmark_configs.py index 4f6155cadd80c..36c404152fe3e 100644 --- a/tests/rptest/services/openmessaging_benchmark_configs.py +++ b/tests/rptest/services/openmessaging_benchmark_configs.py @@ -247,6 +247,19 @@ def validate_metrics(metrics, validator): "warmup_duration_minutes": 5, } + RELEASE_CERT_SMOKE_LOAD_625k_BACKLOG = { + "name": "SmokeLoad625kReleaseCert", + "topics": 1, + "partitions_per_topic": 100, + "subscriptions_per_topic": 1, + "consumer_per_subscription": 8, + "producers_per_topic": 16, + "producer_rate": 625000, + "consumer_backlog_size_GB": 10, + "test_duration_minutes": 5, + "warmup_duration_minutes": 5, + } + # ------- Workload configurations end-------- # We have another level of indirection from name -> driver/workload @@ -280,5 +293,7 @@ def validate_metrics(metrics, validator): "TOPIC1_PART100_1KB_4PROD_1250K_RATE": (TOPIC1_PART100_1KB_4PROD_1250K_RATE, PROD_ENV_VALIDATOR), "RELEASE_CERT_SMOKE_LOAD_625k": - (RELEASE_CERT_SMOKE_LOAD_625k, RELEASE_SMOKE_TEST_VALIDATOR) + (RELEASE_CERT_SMOKE_LOAD_625k, RELEASE_SMOKE_TEST_VALIDATOR), + "RELEASE_CERT_SMOKE_LOAD_625k_BACKLOG": + (RELEASE_CERT_SMOKE_LOAD_625k_BACKLOG, RELEASE_SMOKE_TEST_VALIDATOR) }