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

test/kafka: support archived kafka versions

Browse Source 
Fixes: https://tracker.ceph.com/issues/78214

Signed-off-by: Yuval Lifshitz <ylifshit@ibm.com>
This commit is contained in:
Yuval Lifshitz 2026-07-14 13:20:14 +00:00
parent d24cc5b497
commit c0f1ffb960
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(