[
https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864318#comment-17864318
]
Chia-Ping Tsai commented on KAFKA-16390:
----------------------------------------
It seems current issue is that we don't set
`group.coordinator.rebalance.protocols` when using new coordinator [0].
`consume_bench_test` pass on my local if
`group.coordinator.rebalance.protocols` has correct value.
[~kirktrue] Please correct me if I misunderstand this issue. Or do you plan to
fix it if my comment is correct?
[0]
https://github.com/apache/kafka/blob/cfc7bb90ae40669d6eb284ae1987ce93b14990f4/tests/kafkatest/services/kafka/kafka.py#L784
> 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)
