kafka_rulebook.yml

---
- name: kafka listener
  hosts: all
  sources:
    - name: Checked Kafka
      checked: true
      ansible.eda.kafka:
        host: "{{ MY_KAFKA_HOST | default('localhost') }}"
        topic: "{{ MY_KAFKA_TOPIC | default('demo') }}"
        port: 9092
        offset: latest
     
  rules:
    - name: listener ping
      condition: event.body.payload.ping == "pong"
      action:
        none:
    - name: listener shutdown
      condition: event.body.payload.shutdown is defined
      action:
        shutdown: