From: Kalpesh Pandya <kapandya@redhat.com>
Date: Thu, 11 Nov 2021 06:46:16 +0000 (+0530)
Subject: qa/tasks: Checking for kafka cleanup
X-Git-Tag: v17.1.0~77^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F43995%2Fhead;p=ceph.git

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 <kapandya@redhat.com>
---

diff --git a/qa/tasks/kafka.py b/qa/tasks/kafka.py
index 5d185bba750..48bf3611f5a 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):
     """