From 6135747a06ddcce35a6079ecc76d8ad16988c03c Mon Sep 17 00:00:00 2001 From: Kalpesh Pandya Date: Thu, 11 Nov 2021 12:16:16 +0530 Subject: [PATCH] qa/tasks: Checking for kafka cleanup Adding a sleep after running ./kafka-server-stop.sh and ./zookeeper-server-stop.sh scripts so that nothing gets logged into the kafka logs after the sleep time. And finally killing the process. This resolves: https://tracker.ceph.com/issues/53220 Signed-off-by: Kalpesh Pandya --- qa/tasks/kafka.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/qa/tasks/kafka.py b/qa/tasks/kafka.py index 5d185bba75070..48bf3611f5a18 100644 --- a/qa/tasks/kafka.py +++ b/qa/tasks/kafka.py @@ -3,6 +3,7 @@ Deploy and configure Kafka for Teuthology """ import contextlib import logging +import time from teuthology import misc as teuthology from teuthology import contextutil @@ -116,6 +117,8 @@ def run_kafka(ctx,config): ], ) + time.sleep(5) + ctx.cluster.only(client).run( args=['cd', '{tdir}/bin'.format(tdir=get_kafka_dir(ctx, config)), run.Raw('&&'), './zookeeper-server-stop.sh', @@ -123,6 +126,11 @@ def run_kafka(ctx,config): ], ) + time.sleep(5) + + ctx.cluster.only(client).run(args=['killall', '-9', 'java']) + + @contextlib.contextmanager def run_admin_cmds(ctx,config): """ -- 2.47.3