From dabc1951c2dec40621c1b18cb1d5b74ea1ea7b9e Mon Sep 17 00:00:00 2001 From: Robin Han Date: Tue, 5 Dec 2023 21:16:48 +0800 Subject: [PATCH] fix(e2e): adjust move_start_offset producer throughput Signed-off-by: Robin Han --- tests/kafkatest/tests/core/reassign_partitions_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/kafkatest/tests/core/reassign_partitions_test.py b/tests/kafkatest/tests/core/reassign_partitions_test.py index f1d0e059e9..3d14512774 100644 --- a/tests/kafkatest/tests/core/reassign_partitions_test.py +++ b/tests/kafkatest/tests/core/reassign_partitions_test.py @@ -110,7 +110,7 @@ def move_start_offset(self): and waiting for them to be cleaned up. """ producer = VerifiableProducer(self.test_context, 1, self.kafka, self.topic, - throughput=-1, enable_idempotence=True, + throughput=100, enable_idempotence=True, create_time=1000) producer.start() wait_until(lambda: producer.num_acked > 0,