---
- name: Demo rules with kafka as source
  hosts: localhost
  sources:
    - name: kafka
      kafka:
        topic: eda
        host: localhost
        port: 9092
        group_id: testing
  rules:
    - name:
      condition: event.i is defined
      action:
        debug:
    - name:
      condition: event.stop == true
      action:
        shutdown: