Skip to content

Commit

Permalink
addressed the comment
Browse files Browse the repository at this point in the history
  • Loading branch information
m1a2st committed Feb 22, 2025
1 parent deed48d commit 5c011fe
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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()
Expand Down

0 comments on commit 5c011fe

Please sign in to comment.