[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kirk True reassigned KAFKA-16390: --------------------------------- Assignee: TengYao Chi (was: Kirk True) > consume_bench_test.py failed using AsyncKafkaConsumer > ----------------------------------------------------- > > Key: KAFKA-16390 > URL: https://issues.apache.org/jira/browse/KAFKA-16390 > Project: Kafka > Issue Type: Task > Components: consumer, system tests > Reporter: Philip Nee > Assignee: TengYao Chi > Priority: Major > Labels: kip-848-client-support > > Ran the system test based on KAFKA-16273 > The following tests failed using the consumer group protocol > {code:java} > kafkatest.tests.core.consume_bench_test.ConsumeBenchTest.test_consume_bench.topics=.consume_bench_topic.0-5.0-4.metadata_quorum=ISOLATED_KRAFT.use_new_coordinator=True.group_protocol=consumer > kafkatest.tests.core.consume_bench_test.ConsumeBenchTest.test_multiple_consumers_random_group_partitions.metadata_quorum=ISOLATED_KRAFT.use_new_coordinator=True.group_protocol=consumer > kafkatest.tests.core.consume_bench_test.ConsumeBenchTest.test_single_partition.metadata_quorum=ISOLATED_KRAFT.use_new_coordinator=True.group_protocol=consumer > {code} > Because of > {code:java} > TimeoutError('consume_workload failed to finish in the expected amount of > time.') > Traceback (most recent call last): > File > "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", > line 186, in _do_run > data = self.run_test() > File > "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", > line 246, in run_test > return self.test_context.function(self.test) > File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line > 433, in wrapper > return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) > File "/opt/kafka-dev/tests/kafkatest/tests/core/consume_bench_test.py", > line 146, in test_single_partition > consume_workload.wait_for_done(timeout_sec=180) > File "/opt/kafka-dev/tests/kafkatest/services/trogdor/trogdor.py", line > 352, in wait_for_done > wait_until(lambda: self.done(), > File "/usr/local/lib/python3.9/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: consume_workload failed to finish in the > expected amount of time. {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)