clusterRollingRestart.yml

---

- hosts: clusterNodes:clusterAddNodes
  gather_facts: true
  become: true
  serial: 1
  tasks:
    - name: including restart tasks
      ansible.builtin.import_role:
        name: serviceState
      vars:
        serviceName: kafka
        serviceState: restarted

    - name: kafka port status
      ansible.builtin.include_role:
        name: portCheck
      vars:
        portNumber: "{{ item }}"
        portStatus: started
      loop:
        - "{{ kafkaPort }}"
        - "{{ kafkaJmxPort }}"