@@ -1161,18 +1161,20 @@ def test_ht004_minpartomb(self):
1161
1161
OMBSampleConfigurations .E2E_LATENCY_AVG :
1162
1162
[OMBSampleConfigurations .lte (145 )],
1163
1163
}
1164
- partitions_per_topic = self .config .partitions_max_scaled
1164
+ partitions_per_topic = self .tier_config .partitions_min
1165
+ per_producer_rate = self .tier_config .ingress_rate
1166
+ msg_size = 16 * KiB
1165
1167
workload = {
1166
1168
"name" : "HT004-MINPARTOMB" ,
1167
1169
"topics" : 1 ,
1168
1170
"partitions_per_topic" : partitions_per_topic ,
1169
1171
"subscriptions_per_topic" : 1 ,
1170
- "consumer_per_subscription" : 3 ,
1172
+ "consumer_per_subscription" : 2 ,
1171
1173
"producers_per_topic" : 1 ,
1172
- "producer_rate" : int ( self . config . ingress_rate_scaled / 8 ) ,
1173
- "message_size" : 8 * KiB ,
1174
+ "producer_rate" : per_producer_rate ,
1175
+ "message_size" : msg_size ,
1174
1176
"consumer_backlog_size_GB" : 0 ,
1175
- "test_duration_minutes" : 1 ,
1177
+ "test_duration_minutes" : 30 ,
1176
1178
"warmup_duration_minutes" : 1 ,
1177
1179
"use_randomized_payloads" : True ,
1178
1180
"random_bytes_ratio" : 0.5 ,
0 commit comments