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 5d185bba7507062d91736713067b366f263bdb57..48bf3611f5a18f77bddfa98691279bc281d9f0f7 100644 (file)
--- 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):
     """