[
https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868507#comment-17868507
]
Kirk True commented on KAFKA-16390:
-----------------------------------
[~chia7712]—sorry for the late reply.
What you're suggesting makes sense and I don't see the
{{group.coordinator.rebalance.protocols}} set anywhere either. But I would
think _all_ of the consumer-related tests would fail if that were the case, but
the majority of them pass :(
> 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: Kirk True
> 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)
