root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix transactions_upgrade_test to run transactions during upgrade (#16462) 

Move when the upgrade happens so we actually upgrade while transactions are running

Reviewers: David Jacot <djacot@confluent.io>
This commit is contained in:
Justine Olshan 2024-07-11 10:30:15 -07:00 committed by GitHub
parent a0309be7f4
commit e118811da3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/kafkatest/tests/core/transactions_upgrade_test.py
View File

@ -154,8 +154,6 @@ class TransactionsUpgradeTest(Test):
It returns the concurrently consumed messages. It returns the concurrently consumed messages.
""" """
self.perform_upgrade(from_kafka_version)
copiers = create_and_start_copiers(test_context=self.test_context, copiers = create_and_start_copiers(test_context=self.test_context,
kafka=self.kafka, kafka=self.kafka,
consumer_group=self.consumer_group, consumer_group=self.consumer_group,
@ -169,6 +167,8 @@ class TransactionsUpgradeTest(Test):
group_id="concurrent_consumer", group_id="concurrent_consumer",
group_protocol=group_protocol) group_protocol=group_protocol)
self.perform_upgrade(from_kafka_version)
copier_timeout_sec = 120 copier_timeout_sec = 120
for copier in copiers: for copier in copiers:
wait_until(lambda: copier.is_done, wait_until(lambda: copier.is_done,