mingyen066 commented on PR #20897:
URL: https://github.com/apache/kafka/pull/20897#issuecomment-3544745310
Test result:
```
====================================================================================================
SESSION REPORT (ALL TESTS)
ducktape version: 0.11.4
session_id: 2025-11-17--001
run time: 345 minutes 0.396 seconds
tests run: 153
passed: 151
flaky: 0
failed: 2
ignored: 0
====================================================================================================
...
----------------------------------------------------------------------------------------------------
test_id:
kafkatest.tests.streams.streams_smoke_test.StreamsSmokeTest.test_streams.processing_guarantee=exactly_once_v2.crash=False.metadata_quorum=ZK
status: FAIL
run time: 10 minutes 24.823 seconds
TimeoutError("Never saw 'REBALANCING -> RUNNING' message
ducker@ducker08")
Traceback (most recent call last):
File
"/usr/local/lib/python3.8/dist-packages/ducktape/tests/runner_client.py", line
186, in _do_run
data = self.run_test()
File
"/usr/local/lib/python3.8/dist-packages/ducktape/tests/runner_client.py", line
246, in run_test
return self.test_context.function(self.test)
File "/usr/local/lib/python3.8/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/streams/streams_smoke_test.py",
line 95, in test_streams
monitor3.wait_until('REBALANCING -> RUNNING',
File
"/usr/local/lib/python3.8/dist-packages/ducktape/cluster/remoteaccount.py",
line 753, in wait_until
return wait_until(lambda: self.acct.ssh("tail -c +%d %s | grep '%s'" %
(self.offset + 1, self.log, pattern),
File "/usr/local/lib/python3.8/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: Never saw 'REBALANCING -> RUNNING' message
ducker@ducker08
----------------------------------------------------------------------------------------------------
...
----------------------------------------------------------------------------------------------------
test_id:
kafkatest.tests.streams.streams_broker_compatibility_test.StreamsBrokerCompatibility.test_fail_fast_on_incompatible_brokers_if_eos_v2_enabled.broker_version=1.1.1
status: FAIL
run time: 2 minutes 6.181 seconds
TimeoutError('Never saw \'Shutting down because the Kafka cluster seems
to be on a too old version. Setting
`processing.guarantee="exactly_once_v2"/"exactly_once_beta"` requires broker
version 2.5 or higher.\' log message ducker@ducker04')
Traceback (most recent call last):
File
"/usr/local/lib/python3.8/dist-packages/ducktape/tests/runner_client.py", line
186, in _do_run
data = self.run_test()
File
"/usr/local/lib/python3.8/dist-packages/ducktape/tests/runner_client.py", line
246, in run_test
return self.test_context.function(self.test)
File "/usr/local/lib/python3.8/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/streams/streams_broker_compatibility_test.py",
line 170, in test_fail_fast_on_incompatible_brokers_if_eos_v2_enabled
log.wait_until('Shutting down because the Kafka cluster seems to be on a
too old version. Setting
processing\.guarantee="exactly_once_v2"/"exactly_once_beta" requires broker
version 2\.5 or higher\.',
File
"/usr/local/lib/python3.8/dist-packages/ducktape/cluster/remoteaccount.py",
line 753, in wait_until
return wait_until(lambda: self.acct.ssh("tail -c +%d %s | grep '%s'" %
(self.offset + 1, self.log, pattern),
File "/usr/local/lib/python3.8/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: Never saw 'Shutting down because the Kafka
cluster seems to be on a too old version. Setting
`processing.guarantee="exactly_once_v2"/"exactly_once_beta"` requires broker
version 2.5 or higher.' log message ducker@ducker04
----------------------------------------------------------------------------------------------------
```
--
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]
