aheev commented on PR #20385: URL: https://github.com/apache/kafka/pull/20385#issuecomment-3263872229
@Yunyung _ConsumerPerformanceService_ and _ShareConsumerPerformanceService_ are used in `benchmark_test.py`(which uses DEV_BRANCH and `test_performance_services.py`(which uses LATEST_2_1 and DEV_BRANCH) - _ShareConsumerPerformanceService_ runs [only](https://github.com/apache/kafka/blob/942b11bb3618da3cfefe5a8fdf7376da0ac15590/tests/kafkatest/sanity_checks/test_performance_services.py#L84) in `test_performance_services.py` runs on branches >= 4.1. Hence, we can ignore this - As for _ConsumerPerformanceService_, I have added changes, but, while running the test, `ProducerPerformanceService`, which is used to produce data in turn consumed by _ConsumerPerformanceService_, fails, thereby blocking the _ConsumerPerformanceService_ to consume on LATEST_2_1. It fails on trunk too ``` [INFO:2025-09-07 09:01:58,715]: RunnerClient: kafkatest.sanity_checks.test_performance_services.PerformanceServiceTest.test_version.version=2.1.1.metadata_quorum=ISOLATED_KRAFT: FAIL: Exception('ProducerPerformanceService-0-125869363841104-worker-1: Traceback (most recent call last):\n File "/usr/local/lib/python3.10/dist-packages/ducktape/services/background_thread.py", line 36, in _protected_worker\n self._worker(idx, node)\n File "/opt/kafka-dev/tests/kafkatest/services/performance/producer_performance.py", line 130, in _worker\n wait_until(lambda: self.alive(node), timeout_sec=20, err_msg="ProducerPerformance failed to start")\n File "/usr/local/lib/python3.10/dist-packages/ducktape/utils/util.py", line 58, in wait_until\n raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from last_exception\nducktape.errors.TimeoutError: ProducerPerformance failed to start\n') Traceback (most recent call last): File "/usr/local/lib/python3.10/dist-packages/ducktape/tests/runner_client.py", line 351, in _do_run data = self.run_test() File "/usr/local/lib/python3.10/dist-packages/ducktape/tests/runner_client.py", line 411, in run_test return self.test_context.function(self.test) File "/usr/local/lib/python3.10/dist-packages/ducktape/mark/_mark.py", line 438, in wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) File "/opt/kafka-dev/tests/kafkatest/sanity_checks/test_performance_services.py", line 58, in test_version self.producer_perf.run() File "/usr/local/lib/python3.10/dist-packages/ducktape/services/service.py", line 345, in run self.wait() File "/usr/local/lib/python3.10/dist-packages/ducktape/services/background_thread.py", line 72, in wait self._propagate_exceptions() File "/usr/local/lib/python3.10/dist-packages/ducktape/services/background_thread.py", line 103, in _propagate_exceptions raise Exception(self.errors) Exception: ProducerPerformanceService-0-125869363841104-worker-1: Traceback (most recent call last): File "/usr/local/lib/python3.10/dist-packages/ducktape/services/background_thread.py", line 36, in _protected_worker self._worker(idx, node) File "/opt/kafka-dev/tests/kafkatest/services/performance/producer_performance.py", line 130, in _worker wait_until(lambda: self.alive(node), timeout_sec=20, err_msg="ProducerPerformance failed to start") File "/usr/local/lib/python3.10/dist-packages/ducktape/utils/util.py", line 58, in wait_until raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from last_exception ducktape.errors.TimeoutError: ProducerPerformance failed to start ``` I think we need to fix our test suite first -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
