diff --git a/tests/kafkatest/automq/quota_test.py b/tests/kafkatest/automq/quota_test.py index f597058314..a56b635e4d 100644 --- a/tests/kafkatest/automq/quota_test.py +++ b/tests/kafkatest/automq/quota_test.py @@ -106,16 +106,16 @@ def test_quota(self, broker_in, broker_out): self.kafka.start() records = 50000 self.logger.info(f'update to {broker_in},{broker_out}') - self.test_quota0(records, broker_in, broker_out) + self.do_quota_validate(records, broker_in, broker_out) # quota reduction broker_in = broker_in // 2 broker_out = broker_out // 2 self.update_quota_config(broker_in, broker_out) self.logger.info(f'update to {broker_in},{broker_out}') - self.test_quota0(records, broker_in, broker_out) + self.do_quota_validate(records, broker_in, broker_out) assert self.success, self.msg - def test_quota0(self, num_records, broker_in, broker_out): + def do_quota_validate(self, num_records, broker_in, broker_out): # Produce all messages self.start_perf_producer(num_records=num_records, throughput=-1) # Consume all messages