filebeat.prospectors:
- input_type: log
  paths:
     - /Data/local/ops/collector/data/*/*
     - /Data/logs/*/kpi-event.log
  document_type: metrics
  tail_files: true
output.kafka:
  enabled: true
  hosts: ["{{ kafka_hosts }}"]
  topic: '%{[type]}'
  compression: snappy
  max_message_bytes: 10000000
  worker: 2