MINOR: Fix fail e2e TransactionsMixedVersionsTest#test_transactions_m…

…ixed_versions (#19002) The main root cause is 3dba312, 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]>
apache · Feb 22, 2025 · d820559 · d820559
1 parent 14ebec3
commit d820559
Showing 1 changed file with 5 additions and 6 deletions.
diff --git 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.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 @@ def setup_topics(self):
 
     @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 @@ def test_transactions_mixed_versions(self, old_kafka_version, metadata_quorum=qu
         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()