blob: 08aaf29a15915c36b61d9f98c4797237fbf6f955 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
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'
|
