summaryrefslogtreecommitdiff
path: root/Apache Kafka/3.4.1/kafka/role/tasks/status-check.yml
diff options
context:
space:
mode:
Diffstat (limited to 'Apache Kafka/3.4.1/kafka/role/tasks/status-check.yml')
-rw-r--r--Apache Kafka/3.4.1/kafka/role/tasks/status-check.yml17
1 files changed, 17 insertions, 0 deletions
diff --git a/Apache Kafka/3.4.1/kafka/role/tasks/status-check.yml b/Apache Kafka/3.4.1/kafka/role/tasks/status-check.yml
new file mode 100644
index 0000000..08aaf29
--- /dev/null
+++ b/Apache Kafka/3.4.1/kafka/role/tasks/status-check.yml
@@ -0,0 +1,17 @@
+- name: Waitting for Kafka running,60s
+ shell: sleep 60
+
+- name: Check if the Kafka already exists
+ shell: ps -ef | grep -v grep | grep kafka.Kafka | wc -l
+ register: process_out
+
+- name: Check if the Kafka already exists
+ shell: netstat -anlp | egrep "9092|9094|9095" | grep LISTEN | wc -l
+ register: port_out
+
+- name: To terminate execution
+ fail:
+ msg: "Kafka on node {{ inventory_hostname }} is not started. Please check"
+ run_once: true
+ delegate_to: 127.0.0.1
+ when: process_out.stdout != '1' or port_out.stdout != '3'