This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new d820559751e MINOR: Fix fail e2e
TransactionsMixedVersionsTest#test_transactions_mixed_versions (#19002)
d820559751e is described below
commit d820559751eb516346aaa8ec62545ee84586c940
Author: Ken Huang <[email protected]>
AuthorDate: Sat Feb 22 15:52:22 2025 +0800
MINOR: Fix fail e2e
TransactionsMixedVersionsTest#test_transactions_mixed_versions (#19002)
The main root cause is
https://github.com/apache/kafka/commit/3dba3125e9c81fc9ba301416d708205a53e22aaa,
this PR remove the metadata version which is older than 3.3, thus this
test will fail when it use metadata version 3.2, 3.1
Reviewers: Chia-Ping Tsai <[email protected]>, David Jacot
<[email protected]>
---
.../kafkatest/tests/core/transactions_mixed_versions_test.py | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
diff --git a/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
b/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
index 3347e114a77..6262229069f 100644
--- a/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
+++ b/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
@@ -20,7 +20,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.transactional_message_copier import
TransactionalMessageCopier
from kafkatest.utils import is_int
from kafkatest.utils.transactions_utils import create_and_start_copiers
-from kafkatest.version import LATEST_3_1, LATEST_3_2, LATEST_3_3, LATEST_3_4,
LATEST_3_5, \
+from kafkatest.version import LATEST_3_3, LATEST_3_4, LATEST_3_5, \
LATEST_3_6, LATEST_3_7, LATEST_3_8, LATEST_3_9, DEV_BRANCH, KafkaVersion,
LATEST_STABLE_METADATA_VERSION
from ducktape.tests.test import Test
@@ -178,7 +178,7 @@ class TransactionsMixedVersionsTest(Test):
@cluster(num_nodes=8)
@matrix(
- old_kafka_version=[str(LATEST_3_9), str(LATEST_3_8), str(LATEST_3_7),
str(LATEST_3_6), str(LATEST_3_5), str(LATEST_3_4), str(LATEST_3_3),
str(LATEST_3_2), str(LATEST_3_1)],
+ old_kafka_version=[str(LATEST_3_9), str(LATEST_3_8), str(LATEST_3_7),
str(LATEST_3_6), str(LATEST_3_5), str(LATEST_3_4), str(LATEST_3_3)],
metadata_quorum=[isolated_kraft],
use_new_coordinator=[False],
group_protocol=[None]
@@ -198,10 +198,9 @@ class TransactionsMixedVersionsTest(Test):
self.kafka.interbroker_security_protocol = security_protocol
self.kafka.logs["kafka_data_1"]["collect_default"] = True
self.kafka.logs["kafka_data_2"]["collect_default"] = True
- self.kafka.logs["kafka_operational_logs_debug"]["collect_default"] =
False if old_kafka_version == str(LATEST_3_2) else True
- # The 3.2.3 release does not include KAFKA-14259, which will cause an
exception when writing debug messages.
- # Therefore, changing the log level to INFO can avoid triggering the
bug.
- self.kafka.log_level = "INFO" if old_kafka_version == str(LATEST_3_2)
else "DEBUG"
+ self.kafka.logs["kafka_operational_logs_debug"]["collect_default"] =
True
+
+ self.kafka.log_level = "DEBUG"
self.setup_topics()
self.kafka.start()
