diff --git a/tests/kafkatest/services/kafka/kafka.py b/tests/kafkatest/services/kafka/kafka.py
index 172bf4f5479f..176a4061baeb 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -928,6 +928,26 @@ def pids(self, node):
         try:
             cmd = "jcmd | grep -e %s -e %s | awk '{print $1}'" % (self.java_class_name(), self.deprecated_cp_java_class_name())
             pid_arr = [pid for pid in node.account.ssh_capture(cmd, allow_fail=True, callback=int)]
+            print("\n\nAns0 = ", cmd, pid_arr)
+
+
+            # cmd1 = "jcmd | grep -e %s -e %s" % (self.java_class_name(), self.deprecated_cp_java_class_name())
+            # ans_arr1 = [pid for pid in node.account.ssh_output(cmd1, allow_fail=True, callback=int)]
+            # print("Ans1 is = ", cmd1, ans_arr1)
+
+
+            cmd2 = "ps ax | grep -e %s -e %s | grep -v grep | awk '{print $1}'" % (self.java_class_name(), self.deprecated_cp_java_class_name())
+            ans2 = node.account.ssh_capture(cmd2, allow_fail=True)
+            ans_arr2 = [a for a in ans2]
+            print("Ans1 is = ", cmd2, ans2, ans_arr2)
+
+            cmd3 = "ps ax | grep -e %s -e %s | grep -v grep" % (self.java_class_name(), self.deprecated_cp_java_class_name())
+            ans3 = node.account.ssh_capture(cmd3, allow_fail=True)
+            ans_arr3 = [a for a in ans3]
+            print("Ans3 is = ", cmd3, ans3, ans_arr3)
+            print("\n\n\n\n")
+
+
             return pid_arr
         except (RemoteCommandError, ValueError) as e:
             return []