gian/ceph-mirror
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2026-08-01 22:45:39 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge pull request #70188 from yuvalif/wip-yuval-78214

Browse Source 
test/kafka: support archived kafka versions
This commit is contained in:
Yuval Lifshitz 2026-07-15 14:54:37 +03:00 committed by GitHub
commit 483fe17c2d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
qa/tasks/kafka.py
View File

@ -58,8 +58,13 @@ def install_kafka(ctx, config):
link1 = '{apache_mirror_url_front}/kafka/'.format(apache_mirror_url_front=apache_mirror_url_front) + \
current_version + '/' + kafka_file
archive_link = 'https://archive.apache.org/dist/kafka/' + current_version + '/' + kafka_file
log.info('Trying to download Kafka from mirror: %s', link1)
log.info('Archive fallback URL: %s', archive_link)
ctx.cluster.only(client).run(
args=['cd', '{tdir}'.format(tdir=test_dir), run.Raw('&&'), 'wget', link1],
args=['cd', '{tdir}'.format(tdir=test_dir), run.Raw('&&'),
'wget', link1, run.Raw('||'),
run.Raw('('), 'rm', '-f', kafka_file, run.Raw('&&'), 'wget', archive_link, run.Raw(')')],
)
ctx.cluster.only(client).run(

7
qa/tasks/kafka_failover.py
View File

@ -115,8 +115,13 @@ def install_kafka(ctx, config):
link1 = '{apache_mirror_url_front}/kafka/'.format(apache_mirror_url_front=apache_mirror_url_front) + \
current_version + '/' + kafka_file
archive_link = 'https://archive.apache.org/dist/kafka/' + current_version + '/' + kafka_file
log.info('Trying to download Kafka from mirror: %s', link1)
log.info('Archive fallback URL: %s', archive_link)
ctx.cluster.only(client).run(
args=['cd', '{tdir}'.format(tdir=test_dir), run.Raw('&&'), 'wget', link1],
args=['cd', '{tdir}'.format(tdir=test_dir), run.Raw('&&'),
'wget', link1, run.Raw('||'),
run.Raw('('), 'rm', '-f', kafka_file, run.Raw('&&'), 'wget', archive_link, run.Raw(')')],
)
ctx.cluster.only(client).run(